你们可以 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 >