[hotfix][docs] Rephrase the description about file names in Streaming…

…FileSink
spotify · Aug 7, 2020 · e1b2466 · e1b2466
1 parent 6e8dd29
commit e1b2466
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/...main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/...main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
@@ -61,12 +61,13 @@
  * {@link StreamingFileSink#forBulkFormat(Path, BulkWriter.Factory)}.
  *
  *
- * <p>The filenames of the part files could be defined using {@link OutputFileConfig}, this configuration contain
- * a part prefix and part suffix, that will be used with the parallel subtask index of the sink
- * and a rolling counter. For example for a prefix "prefix" and a suffix ".ext" the file create will have a name
- * {@code "prefix-1-17.ext"} containing the data from {@code subtask 1} of the sink and is the {@code 17th} bucket
+ * <p>The names of the part files could be defined using {@link OutputFileConfig}. This configuration contains
+ * a part prefix and a part suffix that will be used with the parallel subtask index of the sink and a rolling counter
+ * to determine the file names. For example with a prefix "prefix" and a suffix ".ext", a file named
+ * {@code "prefix-1-17.ext"} contains the data from {@code subtask 1} of the sink and is the {@code 17th} bucket
  * created by that subtask.
- * Part files roll based on the user-specified {@link RollingPolicy}. By default, a {@link DefaultRollingPolicy}
+ *
+ * <p>Part files roll based on the user-specified {@link RollingPolicy}. By default, a {@link DefaultRollingPolicy}
  * is used for row-encoded sink output; a {@link OnCheckpointRollingPolicy} is used for bulk-encoded sink output.
  *
  * <p>In some scenarios, the open buckets are required to change based on time. In these cases, the user