Skip to content

Commit db02911

Browse files
committed
fix test
1 parent 280fa3e commit db02911

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImplTest.java

+2
Original file line numberDiff line numberDiff line change
@@ -592,6 +592,8 @@ public void testTopBundlesLoadDataStoreTableViewFromChannelOwner() throws Except
592592
restartBroker();
593593
pulsar1 = pulsar;
594594
setPrimaryLoadManager();
595+
admin.namespaces().setNamespaceReplicationClusters("public/default",
596+
Sets.newHashSet(this.conf.getClusterName()));
595597

596598
var serviceUnitStateChannelPrimaryNew =
597599
(ServiceUnitStateChannelImpl) FieldUtils.readDeclaredField(primaryLoadManager,

0 commit comments

Comments
 (0)