flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor
Date Thu, 03 Dec 2015 12:56:10 GMT
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)

Mime
View raw message