ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-542545383 Hi @pnowojski , I have updated the PR with a hotfix appended. The race condition scenario is when there are too many in-flight checkpoints, the error handling should not release the lock and check whether we should reschedule trigger or not. Because the `triggerRequestQueued` could be changed by IO thread at this time, if we release the lock. BTW, some codes of this PR might not be elegant somewhat. There will be some refactoring in the later PRs.
---------------------------------------------------------------- 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] With regards, Apache Git Services
