summaryrefslogtreecommitdiffstats
path: root/zookeeper-server
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2020-12-02 20:02:34 +0100
committerMartin Polden <mpolden@mpolden.no>2020-12-02 20:02:34 +0100
commitf4194e0ddec44c705416bfa9413a584aaf7abcb4 (patch)
treecc90da6b4e7decd52e81e76d975f0a6f90966b45 /zookeeper-server
parentfac2be2d5f84ee0fbd3c027745a9f30bc6eb489b (diff)
Do not include election 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.java4
1 files changed, 3 insertions, 1 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 32eabc170e3..4a2c3ea5d96 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
@@ -87,7 +87,9 @@ public class Reconfigurer extends AbstractComponent {
}
private String connectionSpec(ZookeeperServerConfig config) {
- return String.join(",", servers(config));
+ return config.server().stream()
+ .map(server -> server.hostname() + ":" + server.quorumPort())
+ .collect(Collectors.joining(","));
}
private static List<String> servers(ZookeeperServerConfig config) {