This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 28e4cf10d11ee80334069faadb4d064c7b124652 Author: Dawid Wysakowicz <dwysakow...@apache.org> AuthorDate: Thu Aug 8 11:49:06 2019 +0200 [hotfix][examples] Changed collection execution environment to regular environment in WordCountTable example --- .../main/java/org/apache/flink/table/examples/java/WordCountTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java index 4da9a1e..d12e0e8 100644 --- a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java +++ b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java @@ -37,7 +37,7 @@ public class WordCountTable { // ************************************************************************* public static void main(String[] args) throws Exception { - ExecutionEnvironment env = ExecutionEnvironment.createCollectionsEnvironment(); + ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); BatchTableEnvironment tEnv = BatchTableEnvironment.create(env); DataSet<WC> input = env.fromElements(