flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot
Date Fri, 16 Oct 2015 16:10:05 GMT

     [ https://issues.apache.org/jira/browse/FLINK-2846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Stephan Ewen closed FLINK-2846.
-------------------------------

> 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)

Mime
View raw message