[bug] fix json parse bug (apache#3624)

if not json array, parse as normal json
ruanwenjun · Dec 5, 2022 · 5e49832 · 5e49832
1 parent be46efc
commit 5e49832
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java b/...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);
         }
     }