This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2e8b35ca08bf706cb2752b692f72eea4c49140fe 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(