This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit aca3cf0fc0967ad3dd95938ecdf71bd2f17ec330 Author: Oneby Wang <[email protected]> AuthorDate: Wed Jan 7 15:49:53 2026 +0800 [fix][test] Wait for txn.abort() to complete to avoid AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() flaky test (#25125) (cherry picked from commit 40953cbeafa10d62fbe982f66410df8895fb7385) --- .../java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java index 7323b57886b..2f1fcf00605 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java @@ -1092,7 +1092,7 @@ public class AdminApiTransactionTest extends MockedPulsarServiceBaseTest { Transaction txn = pulsarClient.newTransaction().build().get(); MessageId messageId = producer.newMessage(txn).value("aborted-msg" + i).send(); abortedMsgIds.add(messageId); - txn.abort(); + txn.abort().get(); } backlogResult = admin.topics().analyzeSubscriptionBacklog(topic, transactionSubName, Optional.empty()); assertEquals(backlogResult.getMessages(), numMessages * 2);
