Repository: storm Updated Branches: refs/heads/master e6a423dd8 -> fc4ac8e2a
fix BlobSynchronizer zk-client non set Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/326afbe6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/326afbe6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/326afbe6 Branch: refs/heads/master Commit: 326afbe6288046a89254a089e9384930ca76713c Parents: 879cb5b Author: chenyuzhao <[email protected]> Authored: Mon Jan 22 22:29:57 2018 +0800 Committer: chenyuzhao <[email protected]> Committed: Mon Jan 22 22:29:57 2018 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/326afbe6/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---------------------------------------------------------------------- diff --git a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java index afb1c28..5a0f622 100644 --- a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java +++ b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java @@ -2283,6 +2283,7 @@ public class Nimbus implements Iface, Shutdownable, DaemonCommon { sync.setNimbusInfo(nimbusInfo); sync.setBlobStoreKeySet(allKeys); sync.setZookeeperKeySet(zkKeys); + sync.setZkClient(zkClient); sync.syncBlobs(); } //else not leader (NOOP) } //else local (NOOP)
