Take a look at https://github.com/apache/storm/blob/7e98f2916a2d6e6087fa09ad8bb7dca45ba3f436/storm-server/src/main/java/org/apache/storm/zookeeper/LeaderElectorImp.java, this is the Nimbus leader election code.
Den tor. 5. sep. 2019 kl. 20.32 skrev Zainal Arifin (BLOOMBERG/ 731 LEX) < [email protected]>: > Hi, > I got this error when browsing Storm UI: > > org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find > leader nimbus from seed hosts ["dev-dob1-tmon-machine-01.foo.dns.com" " > dev-dob1-tmon-machine-02.foo.dns.com" " > dev-dob1-tmon-machine-03.foo.dns.com"]. Did you specify a valid list of > nimbus hosts for config nimbus.seeds? > at > org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:111) > > And in the nimbus log I see many of these lines: > > 2019-09-05 14:27:35.921 o.a.s.d.nimbus timer [INFO] not a leader, skipping > assignments > 2019-09-05 14:27:35.921 o.a.s.d.nimbus timer [INFO] not a leader, skipping > cleanup > > My guess is the data in Zookeeper may got corrupted, since it worked > yesterday for nimbus running on another VM, but I have destroyed the VM, so > maybe it still thinks already-gone node is the leader, and stuck. > Is there a way to safely reset the Storm data in Zookeeper? If yes, which > znodes should I delete? > > Thanks, > Z >
