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 <[email protected]>
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;