Open
Description
Search before asking
- I had searched in the issues and found no similar issues.
Java Version
openjdk version "1.8.0_362"
Scala Version
2.12.x
StreamPark Version
2.1.2
Flink Version
flink-1.17.2
deploy mode
remote
What happened
在 StreamPark 中添加了两个 Flink 集群,在作业管理中手动选择第二个集群进行任务提交。然而,任务实际提交时却被发送到了第一个集群。通过检查数据库 t_flink_app 表中的 job_manager_url 字段发现,其值始终为第一个集群的 URL,但是表中的flink_cluster_id字段是第二个集群的id。
但是,当直接通过 Flink 命令行手动向第二个集群提交任务时,任务可以正常提交到指定集群。
Error Exception
No response
Screenshots
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!(您是否要贡献这个PR?)
Code of Conduct
- I agree to follow this project's Code of Conduct