Re:Flink JOB_MANAGER_LEADER_PATH Znode 疑似泄漏问题

Sat, 27 Jun 2020 19:11:39 -0700 

您的意思是，这些因为Cancel Job的遗留的空的leader/${job_id} ZNode是需要使用者自己定期清理么？




 
 
 
------------------ Original ------------------
From: &nbsp;"Roc Marshal"<[email protected]&gt;;
Date: &nbsp;Sun, Jun 28, 2020 10:07 AM
To: &nbsp;"FLINK中国"<[email protected]&gt;; 

Subject: &nbsp;Re:Flink JOB_MANAGER_LEADER_PATH Znode 疑似泄漏问题

&nbsp;

Hi, 林恬.
首先，感谢你的反馈。
关于zk对应路径下的信息清理问题，你可以简单理解为，Flink对zk组件的依赖，仅在依赖其功能的范围内。并不会提供整个集群或者某个路径下和Flink 
job信息一致性的维护，即不会对其进行无效的信息清理，因为在HA的场景下，对无效路径的判定条件要复杂很多。




Best,
Roc Marshal.

















在 2020-06-28 09:12:41，"林恬" <[email protected]&gt; 写道：
&gt;各位好：
&gt;&amp;nbsp; &amp;nbsp; 目前我使用的是Flink 1.9.2, HA使用ZK， 
使用过程中发现ZK上的/leader/${job_id} 
节点即使作业被Cancel了也不会被清理，导致运行久了之后，/leader/下有大量job_id的空ZNode，请问这块清理时机是什么时候呢？或者说这个没被清理的行为是否是1.9.2的bug呢？
&gt;
&gt;
&gt;&amp;nbsp;

回复