You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/08 06:53:00 UTC

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

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)