dinky
dinky copied to clipboard
[Bug] [admin] 提交yarnsession standalone模式的任务时 flink的配置不生效
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
提交yarnsession standalone模式的任务时 flink的配置不生效
What you expected to happen
standalone 和yarnsession 一样的问题 第一次测试 : 在dinky上直接分别提交两种类型的任务 dinky没有各种set 提交上去无法checkpoint 配置不生效 第二次测试 : 在dinky分别提交两种类型的任务 dinky 加入了set参数 或者使用右侧配置项增加配置 可以做checkpoint 配置生效 第三次测试: 在本地使用sql-client直接提交两种类型的任务 所有任务均正常执行checkpoint 配置生效
How to reproduce
Anything else
1.获取当前关联的 集群实例 的jobmanager
2. 构建 FlinkAPI flinkApi = FlinkAPI.build(jobmanagerAddress)
3. 通过 flinkApi.getJobManagerConfig() 获取到当前 JM的配置 传递给SQL 提交
4. 如果SQL内/右侧配置 中含有 配置项 可覆盖 (3) 中的配置
Version
dev
Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
link to #2762
