(iotdb) branch master updated: Don't print warn msg while meeting 400 (#16597)

[jackietien]

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

jackietien 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 2a120776bce Don't print warn msg while meeting 400 (#16597)
2a120776bce is described below

commit 2a120776bce695a8be9298a04fec7bcde0cdb5b7
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Thu Oct 16 11:00:39 2025 +0800

    Don't print warn msg while meeting 400 (#16597)
---
 .../iotdb/db/protocol/mqtt/MPPPublishHandler.java  | 34 +++++++++++++---------
 1 file changed, 21 insertions(+), 13 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
index c993da93b73..563c6147807 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
@@ -130,16 +130,18 @@ public class MPPPublishHandler extends 
AbstractInterceptHandler {
       MqttClientSession session = clientIdToSessionMap.get(msg.getClientID());
       ByteBuf payload = msg.getPayload();
       String topic = msg.getTopicName();
-      String username = msg.getUsername();
-      MqttQoS qos = msg.getQos();
 
-      LOG.debug(
-          "Receive publish message. clientId: {}, username: {}, qos: {}, 
topic: {}, payload: {}",
-          clientId,
-          username,
-          qos,
-          topic,
-          payload);
+      if (LOG.isDebugEnabled()) {
+        String username = msg.getUsername();
+        MqttQoS qos = msg.getQos();
+        LOG.debug(
+            "Receive publish message. clientId: {}, username: {}, qos: {}, 
topic: {}, payload: {}",
+            clientId,
+            username,
+            qos,
+            topic,
+            payload);
+      }
 
       List<Message> messages = payloadFormat.format(topic, payload);
       if (messages == null) {
@@ -188,8 +190,11 @@ public class MPPPublishHandler extends 
AbstractInterceptHandler {
                   config.getQueryTimeoutThreshold());
 
       tsStatus = result.status;
-      LOG.debug("process result: {}", tsStatus);
-      if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("process result: {}", tsStatus);
+      }
+      if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+          || tsStatus.getCode() != 
TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
         LOG.warn("mqtt line insert error , message = {}", tsStatus.message);
       }
     } catch (Exception e) {
@@ -301,8 +306,11 @@ public class MPPPublishHandler extends 
AbstractInterceptHandler {
                     config.getQueryTimeoutThreshold(),
                     false);
         tsStatus = result.status;
-        LOG.debug("process result: {}", tsStatus);
-        if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) 
{
+        if (LOG.isDebugEnabled()) {
+          LOG.debug("process result: {}", tsStatus);
+        }
+        if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+            || tsStatus.getCode() != 
TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
           LOG.warn("mqtt json insert error , message = {}", tsStatus.message);
         }
       }