[
https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567848#comment-14567848
]
ASF GitHub Bot commented on FLINK-2098:
---------------------------------------
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/742#discussion_r31460503
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -19,66 +19,81 @@
package org.apache.flink.streaming.api.functions.source;
import org.apache.flink.api.common.functions.Function;
+import org.apache.flink.util.Collector;
import java.io.Serializable;
/**
* Base interface for all stream data sources in Flink. The contract of a
stream source
- * is similar to an iterator - it is consumed as in the following pseudo
code:
--- End diff --
Maybe streaming data sources, instead of stream data sources. Not to
confuse with file streams are intermediate results.
> Checkpoint barrier initiation at source is not aligned with snapshotting
> ------------------------------------------------------------------------
>
> Key: FLINK-2098
> URL: https://issues.apache.org/jira/browse/FLINK-2098
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 0.9
> Reporter: Stephan Ewen
> Assignee: Aljoscha Krettek
> Priority: Blocker
> Fix For: 0.9
>
>
> The stream source does not properly align the emission of checkpoint barriers
> with the drawing of snapshots.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
