gaoyunhaii commented on a change in pull request #18068:
URL: https://github.com/apache/flink/pull/18068#discussion_r777164232
##########
File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md
##########
@@ -271,4 +271,8 @@ Any operator that is prepared to be rescaled should work
well with tasks that pa
Restoring from a checkpoint where only a subset of tasks finished is
equivalent to restoring such a
task with the number of new subtasks equal to the number of finished 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.
Review comment:
I split the lines now~
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
