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
openjdk version "1.8.0_362"
2.12.x
2.1.2
flink-1.17.2
remote
在 StreamPark 中添加了两个 Flink 集群,在作业管理中手动选择第二个集群进行任务提交。然而,任务实际提交时却被发送到了第一个集群。通过检查数据库 t_flink_app 表中的 job_manager_url 字段发现,其值始终为第一个集群的 URL,但是表中的flink_cluster_id字段是第二个集群的id。 但是,当直接通过 Flink 命令行手动向第二个集群提交任务时,任务可以正常提交到指定集群。
No response
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Search before asking
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?
Code of Conduct
The text was updated successfully, but these errors were encountered: