pnowojski commented on code in PR #22670: URL: https://github.com/apache/flink/pull/22670#discussion_r1250922307
########## 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 have reached end of data, +without waiting for periodic triggering. Review Comment: Probably not in that case. -- 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
