rkhachatryan opened a new pull request #16328: URL: https://github.com/apache/flink/pull/16328
``` Currently, the test job makes too many attempts with little progress and eventually times out. Too many attempts are made because each checkpoint can be failed by any FailingMapper that reaches its randomly chosen threshold. And if some subtask becomes back-pressured then any of three others will likely fail the checkpoint, reverting the progress. This change makes sources to pause for the checkpoint confirmation; and fixes static fields so that it runs more reliably in a loop locally. ``` -- 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]
