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(

Reply via email to