flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints
Date Tue, 30 Jun 2015 16:06:05 GMT
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

View raw message