You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "TisonKun (JIRA)" <ji...@apache.org> on 2019/02/19 17:18:00 UTC

[jira] [Created] (FLINK-11664) Pass leadership information by LeaderAddressAndId

TisonKun created FLINK-11664:
--------------------------------

             Summary: Pass leadership information by LeaderAddressAndId
                 Key: FLINK-11664
                 URL: https://issues.apache.org/jira/browse/FLINK-11664
             Project: Flink
          Issue Type: Improvement
          Components: Distributed Coordination
    Affects Versions: 1.8.0
            Reporter: TisonKun
            Assignee: TisonKun
             Fix For: 1.8.0


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
(v7.6.3#76005)