[FLINK-18095] Custom Execution Environment for TableEnvironment

• Type: New Feature
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Satyam Shekhar
• Created: 03/Jun/20 18:19
• Updated: 29/Jul/21 07:37

Description

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 StreamExecutionEnvironment.getExecutionEnvironment(). 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.