This is an automated email from the ASF dual-hosted git repository. rgao pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b70f6cdcd3a48550795c2e0e4de86669867b0586 Author: Xiangying Meng <[email protected]> AuthorDate: Wed Feb 16 11:50:41 2022 +0800 [Transaction] Optimize testEndTBRecoveringWhenManagerLedgerDisReadable (#14303) ### Motivation The time used by clean up is too long. This is because the broker service fails to execute the `unloadserviceunit`, and can only rely on the timeout mechanism to cancel the `unloadserviceunit` this time. As a result, the clean up takes too much time. The root cause is that there is a mock cursor in `ManagerLedger.cursors`. ### Modification Remove the cursor from `ManagerLedger.cursors` after test. (cherry picked from commit a43fab0045a93ee864da6bc386bcc0e8bf17bf11) --- .../test/java/org/apache/pulsar/broker/transaction/TransactionTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java index b627438..b882d26 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java @@ -562,6 +562,7 @@ public class TransactionTest extends TransactionTestBase { TransactionBuffer buffer2 = new TopicTransactionBuffer(persistentTopic); Awaitility.await().atMost(30, TimeUnit.SECONDS).untilAsserted(() -> assertEquals(buffer2.getStats().state, "Ready")); + managedCursors.removeCursor("transaction-buffer-sub"); } @Test
