Don't print warn msg while meeting 400 (apache#16597)

Author: JackieTien97

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java

@@ -130,16 +130,18 @@ public void onPublish(InterceptPublishMessage msg) {
       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 @@ private void insertTable(TableMessage message, MqttClientSession session) {
                   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 @@ private void insertTree(TreeMessage message, MqttClientSession session) {
                     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);
         }
       }