Aljoscha Krettek created FLINK-2301:
---------------------------------------
Summary: 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
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)
