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