lindong28 commented on code in PR #22670: URL: https://github.com/apache/flink/pull/22670#discussion_r1243651135
########## docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md: ########## @@ -277,11 +277,10 @@ task with the number of new subtasks equal to the number of running tasks. ### Waiting for the final checkpoint before task exit -To ensure all the records could be committed for operators using the two-phase commit, -the tasks would wait for the final checkpoint completed successfully after all the operators finished. -It needs to be noted that this behavior would prolong the execution time of tasks. -If the checkpoint interval is long, the execution time would also be prolonged largely. -For the worst case, if the checkpoint interval is set to `Long.MAX_VALUE`, -the tasks would in fact be blocked forever since the final checkpoint would never happen. +To ensure all the records could be committed for operators using the two-phase commit, +the tasks would wait for the final checkpoint completed successfully after all the operators finished. +The final checkpoint would be triggered immediately after all operators finished, without waiting Review Comment: "reached end of data" ounds good. ########## docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md: ########## @@ -277,11 +277,10 @@ task with the number of new subtasks equal to the number of running tasks. ### Waiting for the final checkpoint before task exit -To ensure all the records could be committed for operators using the two-phase commit, -the tasks would wait for the final checkpoint completed successfully after all the operators finished. -It needs to be noted that this behavior would prolong the execution time of tasks. -If the checkpoint interval is long, the execution time would also be prolonged largely. -For the worst case, if the checkpoint interval is set to `Long.MAX_VALUE`, -the tasks would in fact be blocked forever since the final checkpoint would never happen. +To ensure all the records could be committed for operators using the two-phase commit, +the tasks would wait for the final checkpoint completed successfully after all the operators finished. +The final checkpoint would be triggered immediately after all operators finished, without waiting Review Comment: Sure, "reached end of data" sounds good. -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
