This is an automated email from the ASF dual-hosted git repository.
yubiao 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 bfc620bf6f2 [fix] [test] fix flaky test
BucketDelayedDeliveryTrackerTest. testWithBkException (#19751)
bfc620bf6f2 is described below
commit bfc620bf6f2586b099fe423d7b07cc88754ef312
Author: fengyubiao <[email protected]>
AuthorDate: Sat Mar 11 13:02:53 2023 +0800
[fix] [test] fix flaky test BucketDelayedDeliveryTrackerTest.
testWithBkException (#19751)
This test sets the maximum number of buckets to 10, then creates multiple
buckets by writing, then uses the merge mechanism to make the final number of
buckets less than or equal to 10.
But `BucketDelayedDeliveryTracker` doesn't guarantee that every merger
operation will work, these cases will make the operation fail:
- the last persistention of the bucket has not finished.
- all buckets are full.
So remove this validation
---
.../broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java
index 08e1f78725b..0ba9e5f4ca2 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java
@@ -308,10 +308,6 @@ public class BucketDelayedDeliveryTrackerTest extends
AbstractDeliveryTrackerTes
assertEquals(110, tracker.getNumberOfDelayedMessages());
- int size = tracker.getImmutableBuckets().asMapOfRanges().size();
-
- assertEquals(10, size);
-
tracker.addMessage(111, 1011, 111 * 10);
MutableLong delayedMessagesInSnapshot = new MutableLong();
