[jira] [Comment Edited] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode

["Maximilian Michels (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-21980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309292#comment-17309292 ] 

Maximilian Michels edited comment on FLINK-21980 at 3/26/21, 9:16 AM:
----------------------------------------------------------------------

Thanks for filing this [~rburnett]! If raised the priority to Critical because this looks like a pretty serious bug in the HA code.


was (Author: mxm):
Thanks for filing this [~rburnett]! If raised the priority to Critical because this looks like a pretty series bug in the HA code.

> ZooKeeperRunningJobsRegistry creates an empty znode
> ---------------------------------------------------
>
>                 Key: FLINK-21980
>                 URL: https://issues.apache.org/jira/browse/FLINK-21980
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination
>    Affects Versions: 1.9.3, 1.10.3, 1.11.3, 1.12.2
>            Reporter: Ricky Burnett
>            Priority: Critical
>             Fix For: 1.12.3
>
>
> ZooKeeperRunningJobsRegistry#writeEnumToZooKeeper calls
> {code:java}
> this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());{code}
> This creates an empty znode in zookeeper.  If the job manager is interrupted at this point the job manager cannot recover.  When trying to restore jobs on a restarted job manager, ZooKeeperRunningJobsRegistry#getJobSchedulingStatus will throw an exception due to the empty znode. 
> Behavior was verified in a test environment where the job manager was interrupted at that point in execution leaving ZK in the following state:
> {code:java}
> zk: localhost:2181(CONNECTED) 2] ls /flink/default
> [checkpoint-counter, checkpoints, jobgraphs, leader, leaderlatch, running_job_registry]
> [zk: localhost:2181(CONNECTED) 3] ls /flink/default/running_job_registry 
> [c982053dd0b9100967e6a9d89202f2a5]
> [zk: localhost:2181(CONNECTED) 4] get /flink/default/running_job_registry/c982053dd0b9100967e6a9d89202f2a5 
> [zk: localhost:2181(CONNECTED) 5] 
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)