You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 林恬 <li...@yottabyte.cn> on 2020/06/23 03:34:05 UTC

Flink JOB_MANAGER_LEADER_PATH Znode的清理时机

各位好：
&nbsp; &nbsp; 目前我使用的是Flink 1.9.2, 使用过程中发现ZK上的/leader/${job_id} 节点即使作业被Cancel了也不会被清理，导致运行久了之后，/leader/下有大量job_id的空ZNode，请问这块清理时机是什么时候呢？


&nbsp;

Re: Flink JOB_MANAGER_LEADER_PATH Znode的清理时机

Posted by Yang Wang <da...@gmail.com>.

如果是Yarn perjob任务的话，当任务正常结束或者被cancel以后，zk整个clusterID的节点会被直接清理掉
如果是Yarn session或Standalone Session的话，和job相关的持久节点是不会被清理的，只有在session结束以后会清理


Best,
Yang

林恬 <li...@yottabyte.cn> 于2020年6月23日周二 上午11:34写道：

> 各位好：
> &nbsp; &nbsp; 目前我使用的是Flink 1.9.2, 使用过程中发现ZK上的/leader/${job_id}
> 节点即使作业被Cancel了也不会被清理，导致运行久了之后，/leader/下有大量job_id的空ZNode，请问这块清理时机是什么时候呢？
>
>
> &nbsp;