Stephan Ewen created FLINK-2846:
-----------------------------------
Summary: Emit checkpoint barriers earlier, before drawing the
state snapshot
Key: FLINK-2846
URL: https://issues.apache.org/jira/browse/FLINK-2846
Project: Flink
Issue Type: Improvement
Components: Streaming
Affects Versions: 0.10
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 0.10
State snapshot drawing and downstream barrier emitting occur in an atomic
scope. Currently, the barriers are emitted after the state snapshot has been
drawn.
There is no reason why the barriers could not be emitted at the beginning of
the atomic scope, and it would reduce the short stalls in the streaming
pipeline when drawing the state snapshot of an operator checkpoint.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
