[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jeff Zhang updated FLINK-15384: ------------------------------- Description: In the new approach of creating TableEnvironement, it is not possible to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironement. This cause the all the features in ExecutionEnvironment/StreamExecutionEnvironment is not available in table api. Such as add JobListener, execute Job async. So I suggest to allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment {code} EnvironmentSettings bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build(); TableEnvironment bbTableEnv = TableEnvironment.create(bbSettings); {code} was: In the new approach of creating TableEnvironement, it is not possible to pass ExecutionEnvironment/StreamExecutionEnvironment. This makes the all the features in ExecutionEnvironment/StreamExecutionEnvironment is not available in table api. Such as add JobListener, execute Job async. So I suggest to allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment {code} EnvironmentSettings bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build(); TableEnvironment bbTableEnv = TableEnvironment.create(bbSettings); {code} > Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to > TableEnvironment > ---------------------------------------------------------------------------------- > > Key: FLINK-15384 > URL: https://issues.apache.org/jira/browse/FLINK-15384 > Project: Flink > Issue Type: Improvement > Components: Table SQL / API > Affects Versions: 1.10.0 > Reporter: Jeff Zhang > Priority: Major > > In the new approach of creating TableEnvironement, it is not possible to pass > ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironement. This > cause the all the features in ExecutionEnvironment/StreamExecutionEnvironment > is not available in table api. Such as add JobListener, execute Job async. So > I suggest to allow to pass ExecutionEnvironment/StreamExecutionEnvironment to > TableEnvironment > {code} > EnvironmentSettings bbSettings = > EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build(); > TableEnvironment bbTableEnv = TableEnvironment.create(bbSettings); > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)