You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/10/21 20:37:04 UTC
(pulsar) branch master updated: [fix][test] Fix running ClusterMetadataSetupTest in IDE (#23492)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 06471dd3054 [fix][test] Fix running ClusterMetadataSetupTest in IDE (#23492)
06471dd3054 is described below
commit 06471dd3054ed47262b09fe0b79263e5abb55580
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Mon Oct 21 23:36:57 2024 +0300
[fix][test] Fix running ClusterMetadataSetupTest in IDE (#23492)
---
.../apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java
index 0c402a83e42..6a7d54dbf7c 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java
@@ -506,11 +506,9 @@ public class ClusterMetadataSetupTest {
private ZooKeeperServer zks;
private NIOServerCnxnFactory serverFactory;
private final int zkPort;
- private final String hostPort;
public ZookeeperServerTest(int zkPort) throws IOException {
this.zkPort = zkPort;
- this.hostPort = "127.0.0.1:" + zkPort;
this.zkTmpDir = File.createTempFile("zookeeper", "test");
log.info("**** Start GZK on {} ****", zkTmpDir);
if (!zkTmpDir.delete() || !zkTmpDir.mkdir()) {
@@ -520,15 +518,17 @@ public class ClusterMetadataSetupTest {
public void start() throws IOException {
try {
+ System.setProperty("zookeeper.4lw.commands.whitelist", "*");
zks = new ZooKeeperServer(zkTmpDir, zkTmpDir, ZooKeeperServer.DEFAULT_TICK_TIME);
zks.setMaxSessionTimeout(20000);
serverFactory = new NIOServerCnxnFactory();
- serverFactory.configure(new InetSocketAddress(zkPort), 1000);
+ serverFactory.configure(new InetSocketAddress("127.0.0.1", zkPort), 1000);
serverFactory.startup(zks);
} catch (Exception e) {
log.error("Exception while instantiating ZooKeeper", e);
}
+ String hostPort = "127.0.0.1:" + serverFactory.getLocalPort();
LocalBookkeeperEnsemble.waitForServerUp(hostPort, 30000);
log.info("ZooKeeper started at {}", hostPort);
}