This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new eb59e49dcff [fix][test] Fix flaky
ModularLoadManagerImplTest.testRemoveNonExistBundleData (#25143)
eb59e49dcff is described below
commit eb59e49dcffd48e95e080983a96092f9a48dc461
Author: Lari Hotari <[email protected]>
AuthorDate: Thu Jan 15 01:05:08 2026 +0200
[fix][test] Fix flaky
ModularLoadManagerImplTest.testRemoveNonExistBundleData (#25143)
---
.../broker/loadbalance/impl/ModularLoadManagerImplTest.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImplTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImplTest.java
index 577a8c19485..f03bd6ed1f9 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImplTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImplTest.java
@@ -1126,10 +1126,12 @@ public class ModularLoadManagerImplTest {
// check bundle data should be deleted from metadata store.
- CompletableFuture<List<String>> childrenAfterSplit =
bundlesCache.getChildren(bundleDataPath);
- List<String> bundlesAfterSplit = childrenAfterSplit.join();
+ Awaitility.await().untilAsserted(() -> {
+ CompletableFuture<List<String>> childrenAfterSplit =
bundlesCache.getChildren(bundleDataPath);
+ List<String> bundlesAfterSplit = childrenAfterSplit.join();
-
assertFalse(bundlesAfterSplit.contains(bundleWillBeSplit.getBundleRange()));
+
assertFalse(bundlesAfterSplit.contains(bundleWillBeSplit.getBundleRange()));
+ });
}
@Test
