[jira] [Created] (FLINK-20047) DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-20047) DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

Shang Yuanchun (Jira)
Yang Wang created FLINK-20047:
---------------------------------

             Summary: DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed
                 Key: FLINK-20047
                 URL: https://issues.apache.org/jira/browse/FLINK-20047
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.12.0
            Reporter: Yang Wang
             Fix For: 1.12.0


Currently, in {{DefaultLeaderRetrievalService}} we are notifying the {{LeaderRetrievalListener}} even though the leader is not truly changed. In Kubernetes HA service, we could get lots of leader information notification events with same leader. Because the ConfigMap is updated periodically. We should filter out these useless events and do not notify the {{LeaderRetrievalListener}}.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)