We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
提交yarnsession standalone模式的任务时 flink的配置不生效
standalone 和yarnsession 一样的问题 第一次测试 : 在dinky上直接分别提交两种类型的任务 dinky没有各种set 提交上去无法checkpoint 配置不生效 第二次测试 : 在dinky分别提交两种类型的任务 dinky 加入了set参数 或者使用右侧配置项增加配置 可以做checkpoint 配置生效 第三次测试: 在本地使用sql-client直接提交两种类型的任务 所有任务均正常执行checkpoint 配置生效
1.获取当前关联的 集群实例 的jobmanager 2. 构建 FlinkAPI flinkApi = FlinkAPI.build(jobmanagerAddress) 3. 通过 flinkApi.getJobManagerConfig() 获取到当前 JM的配置 传递给SQL 提交 4. 如果SQL内/右侧配置 中含有 配置项 可覆盖 (3) 中的配置
dev
The text was updated successfully, but these errors were encountered:
可以参考官方文档 config execution
Sorry, something went wrong.
link to #2762
No branches or pull requests
Search before asking
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?
Code of Conduct
The text was updated successfully, but these errors were encountered: