diff options
| author | Martin Polden <mpolden@mpolden.no> | 2020-12-15 15:18:40 +0100 |
|---|---|---|
| committer | Martin Polden <mpolden@mpolden.no> | 2020-12-15 15:19:11 +0100 |
| commit | 20cd60e994f30c3a3182f2f6f03a097ac41a8e71 (patch) | |
| tree | 0d0b307288ef37eb6e16e8b83623f26d0e184376 | |
| parent | f5ba48c4110dcc3b73154c7e9c014f479b795a88 (diff) | |
Ensure that peer is set before calling start
2 files changed, 2 insertions, 2 deletions
diff --git a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java index 316bf389023..f8ca8987a70 100644 --- a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java +++ b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java @@ -18,8 +18,8 @@ public class ReconfigurableVespaZooKeeperServer extends AbstractComponent implem @Inject public ReconfigurableVespaZooKeeperServer(Reconfigurer reconfigurer, ZookeeperServerConfig zookeeperServerConfig) { + this.peer = new VespaQuorumPeer(); reconfigurer.startOrReconfigure(zookeeperServerConfig, this); - peer = new VespaQuorumPeer(); } @Override diff --git a/zookeeper-server/zookeeper-server-3.6.2/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java b/zookeeper-server/zookeeper-server-3.6.2/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java index 316bf389023..f8ca8987a70 100644 --- a/zookeeper-server/zookeeper-server-3.6.2/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java +++ b/zookeeper-server/zookeeper-server-3.6.2/src/main/java/com/yahoo/vespa/zookeeper/ReconfigurableVespaZooKeeperServer.java @@ -18,8 +18,8 @@ public class ReconfigurableVespaZooKeeperServer extends AbstractComponent implem @Inject public ReconfigurableVespaZooKeeperServer(Reconfigurer reconfigurer, ZookeeperServerConfig zookeeperServerConfig) { + this.peer = new VespaQuorumPeer(); reconfigurer.startOrReconfigure(zookeeperServerConfig, this); - peer = new VespaQuorumPeer(); } @Override |