aboutsummaryrefslogtreecommitdiffstats
path: root/zookeeper-server
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2020-12-03 09:25:21 +0100
committerMartin Polden <mpolden@mpolden.no>2020-12-03 09:25:21 +0100
commit380ef01730e01ec34829a8ab43b3e3af58ee9647 (patch)
tree0b9b4b623b7bd021cbe358200f004458af72edc5 /zookeeper-server
parenta30f94af8019b0316d893fcc45b7f84df6ba068d (diff)
Use client port in connection spec
Diffstat (limited to 'zookeeper-server')
-rw-r--r--zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
index 4a2c3ea5d96..02b58fae21d 100644
--- a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
+++ b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
@@ -88,14 +88,14 @@ public class Reconfigurer extends AbstractComponent {
private String connectionSpec(ZookeeperServerConfig config) {
return config.server().stream()
- .map(server -> server.hostname() + ":" + server.quorumPort())
+ .map(server -> server.hostname() + ":" + config.clientPort())
.collect(Collectors.joining(","));
}
private static List<String> servers(ZookeeperServerConfig config) {
return config.server().stream()
- .map(server -> server.hostname() + ":" + server.quorumPort() + ":" + server.electionPort())
- .collect(Collectors.toList());
+ .map(server -> server.hostname() + ":" + server.quorumPort() + ":" + server.electionPort())
+ .collect(Collectors.toList());
}
ZookeeperServerConfig existingConfig() {