From 16d3d525f9c4c2d86f268adf10baf78ffd1471af Mon Sep 17 00:00:00 2001
From: congbobo184 <congbobo184@github.com>
Date: Thu, 14 Jul 2022 11:22:33 +0800
Subject: [PATCH] [fix][flaky-test] fix cumulative ack test after abort
 redeliver message by users

---
 .../org/apache/pulsar/client/impl/TransactionEndToEndTest.java   | 1 +
 1 file changed, 1 insertion(+)

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 b372f0b61c5f7..72eef04bad96c 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
@@ -606,6 +606,7 @@ private void txnCumulativeAckTest(boolean batchEnable, int maxBatchSize, Subscri
             Assert.assertNull(message);
 
             abortTxn.abort().get();
+            consumer.redeliverUnacknowledgedMessages();
             Transaction commitTxn = getTxn();
             for (int i = 0; i < messageCnt; i++) {
                 message = consumer.receive(1, TimeUnit.SECONDS);