You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "lidesheng (Jira)" <ji...@apache.org> on 2021/02/03 08:52:00 UTC

[jira] [Created] (FLINK-21249) TableEnvironment does not support create method with remote nvironment

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)