kl0u commented on pull request #13985: URL: https://github.com/apache/flink/pull/13985#issuecomment-724021335
Hi @guoweiM , I am not sure that this is enough for the retry logic. The reason is that the `committables` that you want to retry, they are not checkpointed. So if you fail to commit some `committables` and then there is a failure, then these are never going to be committed, right? I have not thought this through but what about a solution that puts the `neededToRetryCommittables` in the pending files for the "next" checkpoint? ---------------------------------------------------------------- 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: [email protected]
