You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by yo...@apache.org on 2021/12/23 14:03:56 UTC
[pulsar] 11/14: Fix flaky test BrokerServiceLookupTest.testModularLoadManagerSplitBundle (#13159)
This is an automated email from the ASF dual-hosted git repository.
yong pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 33bc0cc0cf6a7c3b7af0b245ab8206f1a3f8c342
Author: Zhanpeng Wu <zh...@qq.com>
AuthorDate: Tue Dec 7 21:31:10 2021 +0800
Fix flaky test BrokerServiceLookupTest.testModularLoadManagerSplitBundle (#13159)
Co-authored-by: wuzhanpeng <wu...@bigo.sg>
(cherry picked from commit 4b319f38256d586bf179ac8df9f401709b128b15)
---
.../apache/pulsar/client/api/BrokerServiceLookupTest.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
index 36ff448..3b12dcc 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
@@ -981,15 +981,18 @@ public class BrokerServiceLookupTest extends ProducerConsumerBase {
conf2.setLoadManagerClassName(ModularLoadManagerImpl.class.getName());
conf2.setZookeeperServers("localhost:2181");
conf2.setConfigurationStoreServers("localhost:3181");
-
- @Cleanup
- PulsarService pulsar2 = startBroker(conf2);
+ conf2.setLoadBalancerAutoBundleSplitEnabled(true);
+ conf2.setLoadBalancerAutoUnloadSplitBundlesEnabled(true);
+ conf2.setLoadBalancerNamespaceBundleMaxTopics(1);
// configure broker-1 with ModularLoadManager
stopBroker();
conf.setLoadManagerClassName(ModularLoadManagerImpl.class.getName());
startBroker();
+ @Cleanup
+ PulsarService pulsar2 = startBroker(conf2);
+
pulsar.getLoadManager().get().writeLoadReportOnZookeeper();
pulsar2.getLoadManager().get().writeLoadReportOnZookeeper();
@@ -1059,9 +1062,6 @@ public class BrokerServiceLookupTest extends ProducerConsumerBase {
.getLoadManager().get()).getLoadManager();
updateAllMethod.invoke(loadManager);
- conf2.setLoadBalancerAutoBundleSplitEnabled(true);
- conf2.setLoadBalancerAutoUnloadSplitBundlesEnabled(true);
- conf2.setLoadBalancerNamespaceBundleMaxTopics(1);
loadManager.checkNamespaceBundleSplit();
// (6) Broker-2 should get the watch and update bundle cache