关于 sql-client

1 应该是可以的 主要是你要在flink-conf.yaml里面配置正确的 jobmanager.rpc.address 源码里面有加载主配置文件的逻辑

public LocalExecutor(URL defaultEnv, List jars, List 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实现了一个*来自志愿者整理的flink邮件归档