From c9193438dc45fe42a6dff7ac12df4b758c946a7f Mon Sep 17 00:00:00 2001 From: rdhabalia Date: Wed, 24 Jan 2018 13:48:05 -0800 Subject: [PATCH] fix test with updateCluster --- .../apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java | 1 - .../apache/pulsar/broker/service/BrokerBkEnsemblesTests.java | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java index 8228d21da4a9d..57ed5e5e4d05c 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java @@ -97,7 +97,6 @@ protected void resetConfig() { this.conf.setActiveConsumerFailoverDelayTimeMillis(0); this.conf.setDefaultNumberOfNamespaceBundles(1); this.conf.setZookeeperServers("localhost:2181"); - this.conf.setClusterName("mock"); } protected final void internalSetup() throws Exception { diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java index 347ffaf5640c9..3e1f9d4cbd5fd 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java @@ -92,7 +92,7 @@ void setup() throws Exception { adminUrl = new URL("http://127.0.0.1" + ":" + BROKER_WEBSERVICE_PORT); admin = new PulsarAdmin(adminUrl, (Authentication) null); - admin.clusters().createCluster("usc", new ClusterData(adminUrl.toString())); + admin.clusters().updateCluster("usc", new ClusterData(adminUrl.toString())); admin.properties().createProperty("prop", new PropertyAdmin(Lists.newArrayList("appid1"), Sets.newHashSet("usc"))); } catch (Throwable t) {