Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r152708312
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -1733,13 +1825,24 @@ private TopologyResources
getResourcesForTopology(String topoId, StormBase base)
return ret;
}
+ private boolean isReadyForMKAssignments() throws Exception {
+ if(isLeader()) {
+ if(isHeartbeatsRecovered()) {
+ return true;
+ }
+ LOG.info("waiting for worker heartbeats recovery, skipping
assignments");
--- End diff --
We could change this to `warn`, cause Nimbus leader should be always ready
to do assignments. No assignment due to leader is normal and expected.
---
