dinky icon indicating copy to clipboard operation
dinky copied to clipboard

[FixBug] Fix Exception on Convert.toInt of YarnGateway to track the new JobManager address

Open cantiandashu opened this issue 7 months ago • 1 comments

Purpose of the pull request

Fix dinky cannot track the JobManager address in yarn HA mode https://github.com/DataLinkDC/dinky/issues/4363

Brief change log

getSeconds()*1000 has been added to Convert.toInt in YarnGateway image

Verify this pull request

  1. 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

  2. Dinky submits the application mode job to yarn

  3. Get Jobmanager address from FLINKwebui image

  4. Stop JobManager(kill Jobmanager Process),After that , JobManager address will change kill Jobmanager Process: image JobManager address will change Automatically: image

cantiandashu avatar May 25 '25 12:05 cantiandashu

spotless apply

aiwenmo avatar May 25 '25 15:05 aiwenmo

public static int getZookeeperSessionTimeout(Configuration configuration) { return Convert.toInt(configuration.get(HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT)); }

aiwenmo avatar Aug 19 '25 13:08 aiwenmo