Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202356462 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/table/TableEnvironmentITCase.scala --- @@ -186,7 +186,7 @@ class TableEnvironmentITCase( def testInsertIntoMemoryTable(): Unit = { val env = ExecutionEnvironment.getExecutionEnvironment val tEnv = TableEnvironment.getTableEnvironment(env) - MemoryTableSourceSinkUtil.clear + MemoryTableSourceSinkUtil.clear() --- End diff -- ditto, and same applies probably to hundreds of other changes in this commit :(
---