lidesheng created FLINK-21249: --------------------------------- Summary: TableEnvironment does not support create method with remote nvironment Key: FLINK-21249 URL: https://issues.apache.org/jira/browse/FLINK-21249 Project: Flink Issue Type: Wish Components: Table SQL / API Affects Versions: 1.11.3 Reporter: lidesheng
I want to commit a SQL task to remote long-time session,but TableEnvironment has only one method "create(EnvironmentSettings settings)". In this method , it called create method of ExecutorFactory to create runtime environment. Furthermore, I cannot new instance of TableEnvironment because the constructor of TableEnvironmentImpl is setted to protected. I have to create a new class inherited from TableEnvironmentImpl and rewirte to logic to create TableEnvironment with remote environment. ExecutorFactory interface has two sub class: StreamExecutorFactory and BlinkExecutorFactory and both class support create(settting, env) / create(settings) methods while ExecutorFactory has create(settings) method only . So, if create(settting, env) method is added to ExecutorFactory interface, TableEnvironment can also use add create(settting, env) method to working with remote environment. -- This message was sent by Atlassian Jira (v8.3.4#803005)