diff --git a/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java b/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java
index 1b2a41b19e1..e33a749a35c 100644
--- a/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java
+++ b/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java
@@ -118,6 +118,9 @@ public void collect(byte[] message, Collector<SeaTunnelRow> out) throws IOExcept
                 SeaTunnelRow deserialize = convertJsonNode(arrayNode.get(i));
                 out.collect(deserialize);
             }
+        } else {
+            SeaTunnelRow deserialize = convertJsonNode(jsonNode);
+            out.collect(deserialize);
         }
     }