You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 13:56:10 UTC
[jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start()
can block JobManager actor
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)