This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d558b929a23f34f8ee469b2bc65cc7d4754f4298 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 11ef18b8fd0..2f2e98a0870 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 @@ -1091,7 +1091,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);
