[pulsar] branch branch-2.10 updated: Fix AdminTest#internalConfigurationRetroCompatibility test

[nicoloboschi]

This is an automated email from the ASF dual-hosted git repository.

nicoloboschi pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new df128578bfb Fix AdminTest#internalConfigurationRetroCompatibility test
df128578bfb is described below

commit df128578bfbfc1fa3a5453c948e132d6d52b36d9
Author: Nicolò Boschi <boschi1...@gmail.com>
AuthorDate: Tue Sep 20 12:03:00 2022 +0200

    Fix AdminTest#internalConfigurationRetroCompatibility test
---
 .../src/test/java/org/apache/pulsar/broker/admin/AdminTest.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
index 26c89b4edc4..f3802235686 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
@@ -96,6 +96,7 @@ import org.apache.pulsar.functions.worker.WorkerConfig;
 import org.apache.pulsar.metadata.cache.impl.MetadataCacheImpl;
 import org.apache.pulsar.metadata.impl.AbstractMetadataStore;
 import org.apache.pulsar.metadata.impl.MetadataStoreFactoryImpl;
+import org.apache.pulsar.metadata.impl.ZKMetadataStore;
 import org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData;
 import org.apache.zookeeper.KeeperException.Code;
 import org.apache.zookeeper.MockZooKeeper;
@@ -246,7 +247,8 @@ public class AdminTest extends MockedPulsarServiceBaseTest {
         final InternalConfigurationData newData = 
ObjectMapperFactory.getThreadLocal()
                 .convertValue(oldDataJson, InternalConfigurationData.class);
 
-        assertEquals(newData.getMetadataStoreUrl(), 
conf.getMetadataStoreUrl());
+        assertEquals(newData.getMetadataStoreUrl(),
+                ZKMetadataStore.ZK_SCHEME_IDENTIFIER + 
conf.getMetadataStoreUrl());
         assertEquals(newData.getConfigurationMetadataStoreUrl(), 
oldDataModel.getConfigurationStoreServers());
         assertEquals(newData.getLedgersRootPath(), 
oldDataModel.getLedgersRootPath());
         assertEquals(newData.getBookkeeperMetadataServiceUri(), 
oldDataModel.getBookkeeperMetadataServiceUri());