Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix exception during ingestion

This commit is contained in:
frank chen 2021-09-19 12:28:24 +08:00
parent fa8ffe96d3
commit 5a5484b9ea
1 changed files with 9 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
core/src/main/java/org/apache/druid/java/util/common/parsers/JSONFlattenerMaker.java
View File

@ -86,7 +86,14 @@ public class JSONFlattenerMaker implements ObjectFlatteners.FlattenerMaker<JsonN
public Function<JsonNode, Object> makeJsonPathExtractor(final String expr) public Function<JsonNode, Object> makeJsonPathExtractor(final String expr)
{ {
final JsonPath jsonPath = JsonPath.compile(expr); final JsonPath jsonPath = JsonPath.compile(expr);
return node -> valueConversionFunction(jsonPath.read(node, JSONPATH_CONFIGURATION)); return node -> {
Object val = jsonPath.read(node, JSONPATH_CONFIGURATION);
if (val instanceof JsonNode) {
return valueConversionFunction((JsonNode) val);
} else {
return val;
}
};
} }
@Override @Override
@ -115,17 +122,7 @@ public class JSONFlattenerMaker implements ObjectFlatteners.FlattenerMaker<JsonN
} }
@Nullable @Nullable
private Object valueConversionFunction(Object val) private Object valueConversionFunction(JsonNode val)
{
if (val instanceof JsonNode) {
return convertJsonNode((JsonNode) val);
} else {
return val;
}
}
@Nullable
private Object convertJsonNode(JsonNode val)
{ {
if (val == null || val.isNull()) { if (val == null || val.isNull()) {
return null; return null;