[jira] [Closed] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

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

Aljoscha Krettek closed FLINK-2301.
-----------------------------------

> In BarrierBuffer newer Barriers trigger old Checkpoints
> -------------------------------------------------------
>
>                 Key: FLINK-2301
>                 URL: https://issues.apache.org/jira/browse/FLINK-2301
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>             Fix For: 0.10
>
>
> When the BarrierBuffer has some inputs blocked on barrier 0, then receives barriers for barrier 1 on the other inputs this makes the BarrierBuffer process the checkpoint with id 0.
> I think the BarrierBuffer should drop all previous BarrierCheckpoints when it receives a barrier from a more recent checkpoint and unblock the previously blocked channels. This will make it ready to correctly react to the other barriers of the newer checkpoint. It should also ignore barriers that arrive late when we already processed a more recent checkpoint.



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