[FLINK-11664] Pass leadership information by LeaderAddressAndId

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Do
• Affects Version/s: 1.8.0
• Component/s: Runtime / Coordination
• Assignee: Zili Chen
• Reporter: Zili Chen
• Created: 19/Feb/19 17:17
• Updated: 10/Sep/19 09:18
• Resolved: 10/Sep/19 09:18

Description

We already have LeaderAddressAndId class, and the existing LeaderRetrievalListener#notifyLeaderAddress and LeaderElectionService#confirmLeaderSessionID can benefit from using such an encapsulation to pass leadership information.

Specifically,

LeaderRetrievalListener#notifyLeaderAddress(String leaderAddress, UUID leaderSessionID) → LeaderRetrievalListener#notifyLeadership(LeaderAddressAndId)

LeaderElectionService#confirmLeaderSessionID(UUID leaderSessionID) → LeaderElectionService#publishLeadership(LeaderAddressAndId)

An option is rename LeaderAddressAndId to LeadershipInfo.

cc till.rohrmann

Issue Links

• is superceded by: FLINK-13997 Remove legacy LeaderAddressAndId