[hotfix][examples] Changed collection execution environment to regula…

…r environment in WordCountTable example
spotify · Aug 8, 2019 · 2e8b35c · 2e8b35c
1 parent 434f59f
commit 2e8b35c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java b/...ink-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(