[FLINK-14316] Properly manage rpcConnection in JobManagerLeaderListener under leader change
This commit changes how the rpcConnection is managed in JobManagerLeaderListener under leader change. This component clears now the fields rpcConnection and currentJobMasterId if the leader loses leadership. Moreover, it only restarts a connection attempt if the leader session id is new. This closes #11603.
Showing
想要评论请 注册 或 登录