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)

Reply via email to