-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Open
Labels
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
In Flink on yarn HA mode, dinky cannot track the new JobManager address after the address of the JobManager changes due to automatic fault recovery
What you expected to happen
In Flink on yarn HA mode, dinky automatically tracks the new jobmanager address to ensure that the task is properly monitored
How to reproduce
- Configure high availability mode and ZooKeeper quorum in Flink configuration file:
high-availability.type: zookeeper
high-availability.storageDir: hdfs:///flink/recovery
high-availability.zookeeper.quorum: address1:2181[,...],addressX:2181 - Dinky submits the application mode job to yarn
- Get Jobmanager address from FLINKwebui
- Stop JobManager /Stop NodeManager,After that , JobManager address will change
Anything else
No response
Version
dinky1.2.3+flink1.20
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct
Reactions are currently unavailable

