You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/08/08 09:54:32 UTC
[flink] 01/02: [hotfix][examples] Changed collection execution
environment to regular environment in WordCountTable example
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 <dw...@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(