dawidwys commented on a change in pull request #8984: [FLINK-13088][table-api]
Support lazy query transformation & execution on TableEnvironment
URL: https://github.com/apache/flink/pull/8984#discussion_r300571774
##########
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/harness/TableAggregateHarnessTest.scala
##########
@@ -17,33 +17,37 @@
*/
package org.apache.flink.table.runtime.harness
-import java.lang.{Integer => JInt}
-import java.util.concurrent.ConcurrentLinkedQueue
-
import org.apache.flink.api.common.time.Time
import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord
+import org.apache.flink.table.api.TableConfig
import org.apache.flink.table.api.scala._
-import org.apache.flink.table.runtime.harness.HarnessTestBase._
import org.apache.flink.table.runtime.types.CRow
import org.apache.flink.table.utils.{Top3WithEmitRetractValue, Top3WithMapView}
import org.apache.flink.types.Row
+
import org.junit.Test
+import java.lang.{Integer => JInt}
+import java.util.concurrent.ConcurrentLinkedQueue
+
import scala.collection.mutable
class TableAggregateHarnessTest extends HarnessTestBase {
- protected var queryConfig =
- new TestStreamQueryConfig(Time.seconds(2), Time.seconds(3))
+ private val tableConfig = new TableConfig {
Review comment:
The problem is that we have there a safety check that disallow values used
in those tests. I did not want to rewrite those tests yet.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
