guoweiM commented on a change in pull request #14077: URL: https://github.com/apache/flink/pull/14077#discussion_r524218755
########## File path: docs/dev/connectors/file_sink.zh.md ########## @@ -603,7 +604,7 @@ Flink 有两个内置的 BucketAssigners : ## 滚动策略 -滚动策略 [RollingPolicy]({{ site.javadocs_baseurl }}/api/java/org/apache/flink/streaming/api/functions/sink/filesystem/RollingPolicy.html) 定义了指定的文件在何时关闭(closed)并将其变为 Pending 状态,随后变为 Finished 状态。处于 Pending 状态的文件会在下一次 Checkpoint 时变为 Finished 状态,通过设置 Checkpoint 间隔时间,可以控制部分文件(part file)对下游读取者可用的速度、大小和数量。 +在流模式下,滚动策略 [RollingPolicy]({{ site.javadocs_baseurl }}/api/java/org/apache/flink/streaming/api/functions/sink/filesystem/RollingPolicy.html) 定义了指定的文件在何时关闭(closed)并将其变为 Pending 状态,随后变为 Finished 状态。处于 Pending 状态的文件会在下一次 Checkpoint 时变为 Finished 状态,通过设置 Checkpoint 间隔时间,可以控制部分文件(part file)对下游读取者可用的速度、大小和数量。在批模式下,临时文件只会在作业处理完所有输入数据后提交,此时滚动策略可以用来控制每个文件的大小。 Review comment: Maybe we could not introduce a new concept "临时文件". So maybe we could change to following : 在批模式下,所有文件只会在作业处理完所有输入数据后变为Finished状态 ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org