(pulsar) branch master updated: [fix][test] Wait for txn.abort() to complete to avoid AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() flaky test (#25125)

[xyz]

This is an automated email from the ASF dual-hosted git repository.

xyz 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 40953cbeafa [fix][test] Wait for txn.abort() to complete to avoid 
AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() 
flaky test (#25125)
40953cbeafa is described below

commit 40953cbeafa10d62fbe982f66410df8895fb7385
Author: Oneby Wang <44369297+oneby-w...@users.noreply.github.com>
AuthorDate: Wed Jan 7 15:49:53 2026 +0800

    [fix][test] Wait for txn.abort() to complete to avoid 
AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() 
flaky test (#25125)
---
 .../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);