You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/11/07 17:29:05 UTC
flink git commit: [hotfix] Use correct commit id in
GenericWriteAheadSink.notifyCheckpoint
Repository: flink
Updated Branches:
refs/heads/master 755ae5192 -> 9be150e3d
[hotfix] Use correct commit id in GenericWriteAheadSink.notifyCheckpoint
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9be150e3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9be150e3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9be150e3
Branch: refs/heads/master
Commit: 9be150e3d9dcf86a2b83c0102619db8f3dd5f498
Parents: 755ae51
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Tue Nov 7 18:27:16 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Tue Nov 7 18:28:04 2017 +0100
----------------------------------------------------------------------
.../flink/streaming/runtime/operators/GenericWriteAheadSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9be150e3/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java
index 3dc8857..370d021 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java
@@ -230,7 +230,7 @@ public abstract class GenericWriteAheadSink<IN> extends AbstractStreamOperator<I
in),
serializer),
serializer),
- checkpointId,
+ pastCheckpointId,
timestamp);
if (success) {
// in case the checkpoint was successfully committed,