Re:Flink JOB_MANAGER_LEADER_PATH Znode 疑似泄漏问题
您的意思是,这些因为Cancel Job的遗留的空的leader/${job_id} ZNode是需要使用者自己定期清理么? --Original-- From: "Roc Marshal"
Flink JOB_MANAGER_LEADER_PATH Znode 疑似泄漏问题
各位好: 目前我使用的是Flink 1.9.2, HA使用ZK, 使用过程中发现ZK上的/leader/${job_id} 节点即使作业被Cancel了也不会被清理,导致运行久了之后,/leader/下有大量job_id的空ZNode,请问这块清理时机是什么时候呢?或者说这个没被清理的行为是否是1.9.2的bug呢?
Flink JOB_MANAGER_LEADER_PATH Znode的清理时机
各位好: 目前我使用的是Flink 1.9.2, 使用过程中发现ZK上的/leader/${job_id} 节点即使作业被Cancel了也不会被清理,导致运行久了之后,/leader/下有大量job_id的空ZNode,请问这块清理时机是什么时候呢?