[jira] [Created] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

Shang Yuanchun (Jira)
Paris Carbone created FLINK-1808:
------------------------------------

             Summary: Omit sending checkpoint barriers when the execution graph is not running
                 Key: FLINK-1808
                 URL: https://issues.apache.org/jira/browse/FLINK-1808
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Paris Carbone
            Assignee: Paris Carbone


Currently the StreamCheckpointCoordinator sends barrier requests even when the executionGraph is in FAILING or RESTARTING status which results in unneeded potential communication and space overhead until the job restarts again. It should therefore simply omit sending barriers requests when the execution graph is not in a RUNNING state.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)