This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0458968e74ca9831567901e39b0e9c7b82cd678d Author: Lari Hotari <[email protected]> AuthorDate: Mon Oct 21 23:36:57 2024 +0300 [fix][test] Fix running ClusterMetadataSetupTest in IDE (#23492) (cherry picked from commit 06471dd3054ed47262b09fe0b79263e5abb55580) --- .../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); }
