Re: 关于 sql-client

Thu, 23 Jul 2020 20:42:25 -0700 

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实现了一个




杨荣 <[email protected]> 于2020年7月24日周五 上午10:53写道：

> Hi all,
>
> 请问：
> 1. 在 Embedded mode 下，支持 ClusterClient 进行 job
> 提交作业，进行分布式计算吗？在文档中没看到，跟着文档走，只启起了 Local 在本地作业，无法运用到生产环境。
>
> 2. GateWay mode 预计在那个版本 release？
>


-- 

Best Regards,
Harold Miao

回复