[ https://issues.apache.org/jira/browse/FLINK-3809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15257953#comment-15257953 ]
ASF GitHub Bot commented on FLINK-3809: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1935 > Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() > -------------------------------------------------------------------- > > Key: FLINK-3809 > URL: https://issues.apache.org/jira/browse/FLINK-3809 > Project: Flink > Issue Type: Bug > Reporter: Ted Yu > Assignee: Chesnay Schepler > > {code} > protected void handleStateChange(ConnectionState newState) { > switch (newState) { > case CONNECTED: > LOG.debug("Connected to ZooKeeper quorum. Leader retrieval can > start."); > case SUSPENDED: > LOG.warn("Connection to ZooKeeper suspended. Can no longer retrieve > the leader from " + > "ZooKeeper."); > case RECONNECTED: > LOG.info("Connection to ZooKeeper was reconnected. Leader retrieval > can be restarted."); > case LOST: > LOG.warn("Connection to ZooKeeper lost. Can no longer retrieve the > leader from " + > "ZooKeeper."); > } > {code} > Except for LOST state, the other states would lead to multiple logs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)