You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2018/07/17 21:08:16 UTC
flink git commit: [FLINK-9880] Fix order in BucketerContext#update.
Repository: flink
Updated Branches:
refs/heads/master 690bc370e -> 056486a1b
[FLINK-9880] Fix order in BucketerContext#update.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/056486a1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/056486a1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/056486a1
Branch: refs/heads/master
Commit: 056486a1b81e9648a6d3dc795e7e2c6976f8388c
Parents: 690bc37
Author: kkloudas <kk...@gmail.com>
Authored: Tue Jul 17 23:03:57 2018 +0200
Committer: kkloudas <kk...@gmail.com>
Committed: Tue Jul 17 23:07:47 2018 +0200
----------------------------------------------------------------------
.../streaming/api/functions/sink/filesystem/StreamingFileSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/056486a1/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
index b6fff03..0406afc 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
@@ -332,7 +332,7 @@ public class StreamingFileSink<IN>
final int subtaskIndex = getRuntimeContext().getIndexOfThisSubtask();
// setting the values in the bucketer context
- bucketerContext.update(context.timestamp(), currentProcessingTime, context.currentWatermark());
+ bucketerContext.update(context.timestamp(), context.currentWatermark(), currentProcessingTime);
final String bucketId = bucketer.getBucketId(value, bucketerContext);