You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/09/20 10:03:25 UTC
[pulsar] branch branch-2.10 updated: Fix AdminTest#internalConfigurationRetroCompatibility test
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 <bo...@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());