diff --git a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java index f2eebf377efcb..e712b2e69b956 100644 --- a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java +++ b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java @@ -38,6 +38,7 @@ public interface Bucketer extends Serializable { /** * Returns the {@link Path} of a bucket file. * + * @param clock The current system time in milliseconds. * @param basePath The base path containing all the buckets. * @param element The current element being processed. *