[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645744#comment-14645744
]
ASF GitHub Bot commented on FLINK-2406:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125887226
It failed when at the end of the program, queued channel data was present
at the end of the job. This happens only with slow consumers. Apparently, the
local machines are usually fast enough to never leave queue data, and Travis is
the slow one again ;-)
> Abstract BarrierBuffer to an exchangeable BarrierHandler
> --------------------------------------------------------
>
> Key: FLINK-2406
> URL: https://issues.apache.org/jira/browse/FLINK-2406
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming
> Affects Versions: 0.10
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Fix For: 0.10
>
>
> We need to make the Checkpoint handling pluggable, to allow us to use
> different implementations:
> - BarrierBuffer for "exactly once" processing. This inevitably introduces a
> bit of latency.
> - BarrierTracker for "at least once" processing, with no added latency.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
