Github user Ethanlm commented on the issue:

    https://github.com/apache/storm/pull/2677
  
    There might be a bug in the code: 
https://github.com/apache/storm/blob/master/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java#L490-L497
    ```
            if (leaderElector == null) {
                leaderElector = Zookeeper.zkLeaderElector(conf, zkClient, 
blobStore, topoCache, stormClusterState, getNimbusAcls(conf));
            }
            this.leaderElector = leaderElector;
            this.blobStore.setLeaderElector(this.leaderElector);
            if (topoCache == null) {
                topoCache = new TopoCache(blobStore, conf);
            }
    ```
    `topoCache` initialization should happen before `leaderElector`


---

Reply via email to