This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b480971a1b5d70b9de692f38b69b5578b8ad2355
Author: Timo Walther <twal...@apache.org>
AuthorDate: Fri Nov 9 11:19:53 2018 +0100
[hotfix] [table] Refactor aggregation harness tests to be found
---
...NonWindowHarnessTest.scala => GroupAggregateHarnessTest.scala} | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git
a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/GroupAggregateHarnessTest.scala
similarity index 96%
rename from
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
rename to
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/GroupAggregateHarnessTest.scala
index 7c4f543..8001d79 100644
---
a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
+++
b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/GroupAggregateHarnessTest.scala
@@ -24,20 +24,18 @@ import org.apache.flink.api.common.time.Time
import org.apache.flink.api.common.typeinfo.BasicTypeInfo
import org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord
-import org.apache.flink.table.api.StreamQueryConfig
import org.apache.flink.table.runtime.aggregate._
import org.apache.flink.table.runtime.harness.HarnessTestBase._
import org.apache.flink.table.runtime.types.CRow
-import org.apache.flink.types.Row
import org.junit.Test
-class NonWindowHarnessTest extends HarnessTestBase {
+class GroupAggregateHarnessTest extends HarnessTestBase {
protected var queryConfig =
new TestStreamQueryConfig(Time.seconds(2), Time.seconds(3))
@Test
- def testNonWindow(): Unit = {
+ def testAggregate(): Unit = {
val processFunction = new LegacyKeyedProcessOperator[String, CRow, CRow](
new GroupAggProcessFunction(
@@ -97,7 +95,7 @@ class NonWindowHarnessTest extends HarnessTestBase {
}
@Test
- def testNonWindowWithRetract(): Unit = {
+ def testAggregateWithRetract(): Unit = {
val processFunction = new LegacyKeyedProcessOperator[String, CRow, CRow](
new GroupAggProcessFunction(
