zentol opened a new pull request #15031: URL: https://github.com/apache/flink/pull/15031
Fixes an issue in the `JobLeaderIdService` where the leader future was completed with a null `leaderSessionId`. This happened because `notifyLeaderAddress` can also be called with a null `leaderSessionId` to signal that leadership was revoked without a new leader having been elected. As a result the RM was prematurely rejecting the registration of jobmanagers. We now reset the `leaderIdFuture` if the `leaderSessionId` is null, and only complete it when an actual leader id is provided. ---------------------------------------------------------------- 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]
