[FLINK-9880] Fix order in BucketerContext#update.

laubersder · Jul 17, 2018 · 056486a · 056486a
1 parent 690bc37
commit 056486a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/...main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
@@ -332,7 +332,7 @@ public void invoke(IN value, Context context) throws Exception {
  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);