Aitozi opened a new pull request, #20256: URL: https://github.com/apache/flink/pull/20256
…after the recovery phase has finished ## What is the purpose of the change This PR is meant to solve the problem of request the extra worker after JobManager failover. Related issue: https://issues.apache.org/jira/browse/FLINK-24713 https://issues.apache.org/jira/browse/FLINK-27576 Based on https://github.com/apache/flink/pull/19786 ## Brief change log - Add the getRecoveryFuture interface in `resourceManager` to let the subclass to tell whether it is ready to serve. - Postpone the process resource until the recovery future is ready. ## Verifying this change Two tests are added to verify the change. -- 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]
