你们可以 pr 到官方啊。我觉得这个功能很刚需啊,并且 basic 版的 1.5 就 release 了,不知道为什么相关 gate way 或者
submit with sql file 的 feature 到现在都还没实现呢。

Harold.Miao <miaohong...@gmail.com> 于2020年7月24日周五 上午11:42写道:

> 1 应该是可以的   主要是你要在flink-conf.yaml里面配置正确的 jobmanager.rpc.address
> 源码里面有加载主配置文件的逻辑
>
> public LocalExecutor(URL defaultEnv, List<URL> jars, List<URL> libraries) {
>    // discover configuration
>    final String flinkConfigDir;
>    try {
>       // find the configuration directory
>       flinkConfigDir = CliFrontend.getConfigurationDirectoryFromEnv();
>
>       // load the global configuration
>       this.flinkConfig =
> GlobalConfiguration.loadConfiguration(flinkConfigDir);
>
>       // initialize default file system
>       FileSystem.initialize(flinkConfig,
> PluginUtils.createPluginManagerFromRootFolder(flinkConfig));
>
>       // load command lines for deployment
>       this.commandLines =
> CliFrontend.loadCustomCommandLines(flinkConfig, flinkConfigDir);
>       this.commandLineOptions = collectCommandLineOptions(commandLines);
>    } catch (Exception e) {
>       throw new SqlClientException("Could not load Flink configuration.",
> e);
>    }
>
>
> 2  因为等不及官方的  我们自己wrapper实现了一个
>
>
>
>
> 杨荣 <samyang31...@gmail.com> 于2020年7月24日周五 上午10:53写道:
>
> > Hi all,
> >
> > 请问:
> > 1. 在 Embedded mode 下,支持 ClusterClient 进行 job
> > 提交作业,进行分布式计算吗?在文档中没看到,跟着文档走,只启起了 Local 在本地作业,无法运用到生产环境。
> >
> > 2. GateWay mode 预计在那个版本 release?
> >
>
>
> --
>
> Best Regards,
> Harold Miao
>

回复