From 9079262aaedce719bda786a63781292a4257e299 Mon Sep 17 00:00:00 2001 From: Philipp Dolif <52791955+pdolif@users.noreply.github.com> Date: Tue, 28 Jan 2025 23:17:21 +0100 Subject: [PATCH] [fix][test] Fix flaky DelayedDeliveryTest.testEnableTopicDelayedDelivery (#23893) --- .../pulsar/broker/service/persistent/DelayedDeliveryTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java index e47857e8ec60f..793a1767fd8c5 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java @@ -483,10 +483,10 @@ public void testEnableTopicDelayedDelivery() throws Exception { break; } } - producer.newMessage().value("long-tick-msg").deliverAfter(2, TimeUnit.SECONDS).send(); + producer.newMessage().value("long-tick-msg").deliverAfter(3, TimeUnit.SECONDS).send(); msg = consumer.receive(1, TimeUnit.SECONDS); assertNull(msg); - msg = consumer.receive(3, TimeUnit.SECONDS); + msg = consumer.receive(4, TimeUnit.SECONDS); assertNotNull(msg); }