[
https://issues.apache.org/jira/browse/FLINK-11664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-11664.
----------------------------
Resolution: Won't Do
> Pass leadership information by LeaderAddressAndId
> -------------------------------------------------
>
> Key: FLINK-11664
> URL: https://issues.apache.org/jira/browse/FLINK-11664
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Coordination
> Affects Versions: 1.8.0
> Reporter: TisonKun
> Assignee: TisonKun
> Priority: Minor
>
> 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]
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
