[jira] [Created] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other

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

[jira] [Created] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other

Shang Yuanchun (Jira)
Stephan Ewen created FLINK-2339:
-----------------------------------

             Summary: Prevent asynchronous checkpoint calls from overtaking each other
                 Key: FLINK-2339
                 URL: https://issues.apache.org/jira/browse/FLINK-2339
             Project: Flink
          Issue Type: Improvement
          Components: TaskManager
    Affects Versions: 0.10
            Reporter: Stephan Ewen
            Assignee: Stephan Ewen
             Fix For: 0.10


Currently, when checkpoint state materialization takes very long, and the checkpoint interval is low, the asynchronous calls to trigger checkpoints (on the sources) could overtake prior calls.

We can fix that by making sure that all calls are dispatched in order by the same thread, rather than spawning a new thread for each call.



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