You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/15 09:17:44 UTC

[flink] 03/03: [hotfix] [fs] Add clock as an argument in Javadocs

This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit e7b02b42364563dfa20c8189da50d1a0a7529f4a
Author: Fokko Driesprong <fo...@apache.org>
AuthorDate: Mon Jan 14 14:54:32 2019 +0100

    [hotfix] [fs] Add clock as an argument in Javadocs
    
    The clock parameter is missing in the docstring.
    
    This closes #7484.
---
 .../org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java     | 1 +
 1 file changed, 1 insertion(+)

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 f2eebf3..e712b2e 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<T> 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.
 	 *