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)
