[jira] [Created] (FLINK-18095) Custom Execution Environment for TableEnvironment

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18095) Custom Execution Environment for TableEnvironment

Shang Yuanchun (Jira)
Satyam Shekhar created FLINK-18095:
--------------------------------------

             Summary: Custom Execution Environment for TableEnvironment
                 Key: FLINK-18095
                 URL: https://issues.apache.org/jira/browse/FLINK-18095
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / API
    Affects Versions: 1.10.0
            Reporter: Satyam Shekhar


The recommended pattern for creating a TableEnvironment that uses Blink planner in batch mode is the following -
 
var settings = EnvironmentSettings.newInstance()
                  .useBlinkPlanner()
                  .inBatchMode()
                  .build();
var tEnv = TableEnvironment.create(settings);
 
The above configuration, however, does not allow injecting an ExecutionEnvironment in TableEnvironment. Instead, TableEnvironment is hardcoded to always get the ExecutionEnvironment via ExecutionEnvironment. This limits users to connect to a remote environment while working with TableEnvironment.
 
The workaround suggested by [~godfreyhe] and [~jark] is to directly create a StreamTableEnvironmentImpl instance through StreamTableEnvironmentImpl 
constructor instead of create method.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)