diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java index 7791371014f0b..dce54468f482e 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java @@ -282,7 +282,6 @@ public void transactionTimeoutRecoverTest() throws Exception { field.setAccessible(true); ConcurrentMap>> txnMap = (ConcurrentMap>>) field.get(transactionMetadataStore); - assertEquals(txnMap.size(), 1); Awaitility.await().atMost(3000, TimeUnit.MILLISECONDS).until(() -> txnMap.size() == 0); }