You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/01/08 16:41:23 UTC
(pulsar) 02/02: [fix][test] Wait for txn.abort() to complete to avoid AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() flaky test (#25125)
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 <44...@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)
(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);