[jira] [Assigned] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange()

["Chesnay Schepler (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-3809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler reassigned FLINK-3809:
---------------------------------------

    Assignee: Chesnay Schepler

> 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)