This is an automated email from the ASF dual-hosted git repository.
lhotari 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 ee007eecd80 [fix][test] Fix flaky testClear in
BucketDelayedDeliveryTrackerTest (#25424)
ee007eecd80 is described below
commit ee007eecd806bf5e799a1f47abb7d7801425a1f5
Author: Matteo Merli <[email protected]>
AuthorDate: Mon Mar 30 15:52:29 2026 -0700
[fix][test] Fix flaky testClear in BucketDelayedDeliveryTrackerTest (#25424)
---
.../broker/delayed/bucket/BucketDelayedDeliveryTrackerTest.java | 4 ++++
1 file changed, 4 insertions(+)
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 dd5eb5ad644..efce0f1d8e5 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
@@ -151,6 +151,10 @@ public class BucketDelayedDeliveryTrackerTest extends
AbstractDeliveryTrackerTes
new BucketDelayedDeliveryTracker(dispatcher, timer,
100000, clock,
true, bucketSnapshotStorage, 20,
TimeUnit.HOURS.toMillis(1), 5, 100)
}};
+ case "testClear" -> new Object[][]{{
+ new BucketDelayedDeliveryTracker(dispatcher, timer,
100000, clock,
+ true, bucketSnapshotStorage, 1000,
TimeUnit.MILLISECONDS.toMillis(100), -1, 50)
+ }};
default -> new Object[][]{{
new BucketDelayedDeliveryTracker(dispatcher, timer, 1,
clock,
true, bucketSnapshotStorage, 1000,
TimeUnit.MILLISECONDS.toMillis(100), -1, 50)