退订
在 yarn 上提交 job 可以,不代表通过 sql-client 可以,他们使用的是不同的脚本和配置。前者跟 bin/flink,
bin/yarn-session.sh, conf/flink-conf.yaml 有关,后跟 bin/sql-client.sh,
conf/sql-client-defaults.yaml 有关。
你可以理一下这个逻辑,或者给出你的相关配置文件,以及 sql-client.sh 启动完整命令。
op <520075...@qq.com> 于2020年7月27日周一 下午5:29写道:
> 你好,
> 很确定,检查了好几遍,提交到yarn上执行都
hi,
你能确定你的 class path 下有 mysql-connector-java-5.1.38.jar 依赖吗?请在运行时确认下这一点。
op <520075...@qq.com> 于2020年7月27日周一 下午2:45写道:
> 您好,我创建了一个jdbc的表
>
>
> CREATE TABLE mvp_dim_anticheat_args_all (
> id BIGINT,
> dt STRING,
> cnt_7d INT,
> cnt_30d INT,
> PRIMARY KEY (id) NOT ENFORCED
> ) WI
this.commandLines =
> CliFrontend.loadCustomCommandLines(flinkConfig, flinkConfigDir);
> this.commandLineOptions = collectCommandLineOptions(commandLines);
>} catch (Exception e) {
> throw new SqlClientException("Could not load Flink configuration.",
> e);
>
Hi all,
请问:
1. 在 Embedded mode 下,支持 ClusterClient 进行 job
提交作业,进行分布式计算吗?在文档中没看到,跟着文档走,只启起了 Local 在本地作业,无法运用到生产环境。
2. GateWay mode 预计在那个版本 release?
退出