Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.6.0
-
None
Description
In StreamingFileSink.java :
bucketerContext.update(context.timestamp(), currentProcessingTime, context.currentWatermark());
However, the method update is declared as :
void update(@Nullable Long elementTimestamp, long currentWatermark, long currentProcessingTime) {
The second and third parameters seem to be swapped.