Ufuk Celebi created FLINK-3107: ---------------------------------- Summary: ZooKeeperCheckpointIDCounter.start() can block JobManager actor Key: FLINK-3107 URL: https://issues.apache.org/jira/browse/FLINK-3107 Project: Flink Issue Type: Bug Components: JobManager Affects Versions: 0.10.1 Reporter: Ufuk Celebi
In HA mode, the job manager enables checkpoints during submission of streaming programs. This leads to call to ZooKeeperCheckpointIDCounter.start(), which communicates with ZooKeeper. This can block the job manager actor. A solution is to start the counter later instead of the CheckpointCoordinator constructor. -- This message was sent by Atlassian JIRA (v6.3.4#6332)