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_r300571995
##########
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/harness/GroupAggregateHarnessTest.scala
##########
@@ -185,7 +191,7 @@ class GroupAggregateHarnessTest extends HarnessTestBase {
@Test
def testDistinctAggregateWithRetract(): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
- val tEnv = StreamTableEnvironment.create(env)
+ val tEnv = StreamTableEnvironment.create(env, tableConfig)
Review comment:
Unfortunately this is the only way as of now to pass the custom TableConfig,
which we have to use because of the incompatible values used in these tests
(see comment below)
----------------------------------------------------------------
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
