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 563c614780700..a0c0e1a709bbd 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
@@ -194,8 +194,11 @@ private void insertTable(TableMessage message, MqttClientSession session) {
         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);
+          && tsStatus.getCode() != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
+        LOG.warn(
+            "mqtt json insert error, code={}, message={}",
+            tsStatus.getCode(),
+            tsStatus.getMessage());
       }
     } catch (Exception e) {
       LOG.warn(