Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.14.2
-
None
-
None
Description
Run a job with flink 1.14.2 by configure the zookeeper ha
high-availability.storageDir: hdfs://testcluster/app/ha
high-availability: zookeeper
high-availability.zookeeper.quorum: *****
high-availability.zookeeper.path.root: /flink
when the zookeeper node restart, I see the JM failover with log "Close and clean up all data for ZookeeperHaServices", So the ha data was cleaned when the first JM shutdown.
when the second JM was started, the log was "No checkpoint found during restore", and no checkpoint to restored .
From debug, I find when job failover, it would goto the `ClusterEntryPoint.java` line 285
and will set the `cleanupHaData` as true.