From 4b676340216e7e43b7481f1587d92f39bb9ceddf Mon Sep 17 00:00:00 2001 From: liangyepianzhou Date: Wed, 23 Nov 2022 18:56:19 +0800 Subject: [PATCH] fix --- .../org/apache/pulsar/client/impl/TransactionEndToEndTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java index 46fa00c005890..663c1c50ce79c 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java @@ -942,7 +942,7 @@ public void transactionTimeoutTest() throws Exception { Message reReceiveMessage = consumer.receive(300, TimeUnit.MILLISECONDS); assertNull(reReceiveMessage); - reReceiveMessage = consumer.receive(2, TimeUnit.SECONDS); + reReceiveMessage = consumer.receive(5, TimeUnit.SECONDS); assertEquals(reReceiveMessage.getValue(), message.getValue());