[Transaction] Fix transaction buffer handler sync problem. (apache#10424

)
m00119022 · Apr 29, 2021 · 5238822 · 5238822
1 parent 55867f1
commit 5238822
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferHandlerImpl.java b/...n/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferHandlerImpl.java
@@ -129,7 +129,7 @@ private CompletableFuture<TxnID> endTxn(long requestId, String topic, ByteBuf cm
                 if (throwable == null) {
                     if (clientCnx.ctx().channel().isActive()) {
                         clientCnx.registerTransactionBufferHandler(TransactionBufferHandlerImpl.this);
-                        synchronized (TransactionBufferHandlerImpl.class) {
+                        synchronized (TransactionBufferHandlerImpl.this) {
                             pendingRequests.put(requestId, op);
                             cmd.retain();
                         }