Skip to content

Commit df12857

Browse files
committed
Fix AdminTest#internalConfigurationRetroCompatibility test
1 parent 65c059a commit df12857

File tree

1 file changed

+3
-1
lines changed
  • pulsar-broker/src/test/java/org/apache/pulsar/broker/admin

1 file changed

+3
-1
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@
9696
import org.apache.pulsar.metadata.cache.impl.MetadataCacheImpl;
9797
import org.apache.pulsar.metadata.impl.AbstractMetadataStore;
9898
import org.apache.pulsar.metadata.impl.MetadataStoreFactoryImpl;
99+
import org.apache.pulsar.metadata.impl.ZKMetadataStore;
99100
import org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData;
100101
import org.apache.zookeeper.KeeperException.Code;
101102
import org.apache.zookeeper.MockZooKeeper;
@@ -246,7 +247,8 @@ public void internalConfigurationRetroCompatibility() throws Exception {
246247
final InternalConfigurationData newData = ObjectMapperFactory.getThreadLocal()
247248
.convertValue(oldDataJson, InternalConfigurationData.class);
248249

249-
assertEquals(newData.getMetadataStoreUrl(), conf.getMetadataStoreUrl());
250+
assertEquals(newData.getMetadataStoreUrl(),
251+
ZKMetadataStore.ZK_SCHEME_IDENTIFIER + conf.getMetadataStoreUrl());
250252
assertEquals(newData.getConfigurationMetadataStoreUrl(), oldDataModel.getConfigurationStoreServers());
251253
assertEquals(newData.getLedgersRootPath(), oldDataModel.getLedgersRootPath());
252254
assertEquals(newData.getBookkeeperMetadataServiceUri(), oldDataModel.getBookkeeperMetadataServiceUri());

0 commit comments

Comments
 (0)