(iotdb) 01/01: Don't print warn msg while meeting 400

[jackietien]

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

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

commit 9d3a33e17ceb150d4a04e27b0d746bf5c3b8e3c9
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Thu Oct 16 10:54:51 2025 +0800

    Don't print warn msg while meeting 400
---
 .../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);
         }
       }