[flinksql][kafka source解析json数据为null][21182]

Author: xiuzhu9527

core/src/main/java/com/dtstack/flink/sql/source/JsonDataParser.java

@@ -119,9 +119,8 @@ private void parseTree(JsonNode jsonNode, String prefix){
             JsonNode child = jsonNode.get(next);
             String nodeKey = getNodeKey(prefix, next);
 
-            if (child.isValueNode()){
-                nodeAndJsonNodeMapping.put(nodeKey, child);
-            }else if(child.isArray()){
+            nodeAndJsonNodeMapping.put(nodeKey, child);
+            if(child.isArray()){
                 parseTree(child, nodeKey);
             }else {
                 parseTree(child, nodeKey);