This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b162d469069 [cleanup][broker] remove useless code comment (#22459)
b162d469069 is described below
commit b162d46906961623db09c97df3f06b7876cddb5e
Author: thetumbled <[email protected]>
AuthorDate: Tue Apr 9 13:14:25 2024 +0800
[cleanup][broker] remove useless code comment (#22459)
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 3 ---
1 file changed, 3 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 1650e449a3f..b21cd165402 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -3875,9 +3875,6 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
@Override
public void publishTxnMessage(TxnID txnID, ByteBuf headersAndPayload,
PublishContext publishContext) {
pendingWriteOps.incrementAndGet();
- // in order to avoid the opAddEntry retain
-
- // in order to promise the publish txn message orderly, we should
change the transactionCompletableFuture
if (isFenced) {
publishContext.completed(new TopicFencedException("fenced"), -1,
-1);