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)