diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java index 20068dfc16ac6..d5dbe083d9537 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java @@ -381,7 +381,7 @@ public void openReadOnlyManagedLedgerFailed(ManagedLedgerException exception, Ob So that we can trim the expired snapshot segment in aborts according to the latest transaction IDs in the segmentIndex. */ - synchronized(unsealedTxnIds){ + synchronized (unsealedTxnIds) { unsealedTxnIds.forEach(txnID -> aborts.put(txnID, txnID)); } return CompletableFuture.completedFuture(finalStartReadCursorPosition);