(iotdb) branch master updated: [Subscription] Reduce consensus commit warning log noise (#18450)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 0a9fda0a4c3 [Subscription] Reduce consensus commit warning log noise 
(#18450)
0a9fda0a4c3 is described below

commit 0a9fda0a4c3540e759413b1c496b3d3472dd50c9
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Aug 24 11:48:19 2026 +0800

    [Subscription] Reduce consensus commit warning log noise (#18450)
---
 .../broker/ConsensusSubscriptionBroker.java        | 26 ++++++++++++++++------
 .../ConsensusSubscriptionCommitManager.java        |  4 +++-
 2 files changed, 22 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java
index e1696d59b17..441f6ac0daf 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java
@@ -278,13 +278,25 @@ public class ConsensusSubscriptionBroker implements 
ISubscriptionBroker {
         }
       }
       if (!handled) {
-        LOGGER.warn(
-            DataNodePipeMessages
-                
.PIPE_LOG_CONSENSUSSUBSCRIPTIONBROKER_COMMIT_CONTEXT_NOT_FOUND_IN_46DF62A6,
-            brokerId,
-            commitContext,
-            queues.size(),
-            topicName);
+        // SubscriptionReceiverV1 summarizes rejected ACKs once per request. 
Keep the context-level
+        // detail at DEBUG to avoid one WARN per context, while preserving 
WARN for internal NACKs.
+        if (nack) {
+          LOGGER.warn(
+              DataNodePipeMessages
+                  
.PIPE_LOG_CONSENSUSSUBSCRIPTIONBROKER_COMMIT_CONTEXT_NOT_FOUND_IN_46DF62A6,
+              brokerId,
+              commitContext,
+              queues.size(),
+              topicName);
+        } else {
+          LOGGER.debug(
+              DataNodePipeMessages
+                  
.PIPE_LOG_CONSENSUSSUBSCRIPTIONBROKER_COMMIT_CONTEXT_NOT_FOUND_IN_46DF62A6,
+              brokerId,
+              commitContext,
+              queues.size(),
+              topicName);
+        }
       }
     }
     return successfulCommitContexts;
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitManager.java
index 4daa503ce1a..7d5edd25828 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitManager.java
@@ -1783,7 +1783,9 @@ public class ConsensusSubscriptionCommitManager {
 
         final ProgressKey outstandingKey = 
outstandingKeys.remove(ProgressSlot.from(incomingKey));
         if (Objects.isNull(outstandingKey)) {
-          LOGGER.warn(
+          // Late or duplicate ACKs are reported by the queue or summarized by 
the receiver. Logging
+          // every missing mapping at WARN would amplify one commit request by 
its context count.
+          LOGGER.debug(
               DataNodePipeMessages
                   
.PIPE_LOG_CONSENSUSSUBSCRIPTIONCOMMITSTATE_REJECT_DIRECT_COMMIT_WITHOUT_5B975E49,
               incomingKey.physicalTime,