You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/08/07 11:35:25 UTC
[flink] branch master updated: [FLINK-10055][javadocs] Fix
in-progress file suffix in BucketingSink
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 06dffc3 [FLINK-10055][javadocs] Fix in-progress file suffix in BucketingSink
06dffc3 is described below
commit 06dffc3287c8b1c00d052081ccc22846983beb13
Author: Bowen Li <bo...@gmail.com>
AuthorDate: Tue Aug 7 04:35:21 2018 -0700
[FLINK-10055][javadocs] Fix in-progress file suffix in BucketingSink
---
.../apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
index 17e5d56..d563bcf 100644
--- a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
+++ b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
@@ -1001,7 +1001,7 @@ public class BucketingSink<T>
}
/**
- * Sets the suffix of in-progress part files. The default is {@code "in-progress"}.
+ * Sets the suffix of in-progress part files. The default is {@code ".in-progress"}.
*/
public BucketingSink<T> setInProgressSuffix(String inProgressSuffix) {
this.inProgressSuffix = inProgressSuffix;