[
https://issues.apache.org/jira/browse/FLINK-2301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2301.
-------------------------------------
Resolution: Fixed
Fix Version/s: 0.10
Fixed in a2eb6cc8774ab43475829b0b691e62739fbbe88b
> 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)
