Skip to content

Commit 990e24c

Browse files
committed
PR Feedback
1 parent ec42b6c commit 990e24c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

modules/ingest-common/src/main/java/org/elasticsearch/ingest/common/JsonProcessor.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -188,11 +188,12 @@ public static void recursiveMerge(Map<String, Object> target, Map<String, Object
188188

189189
@Override
190190
public IngestDocument execute(IngestDocument document) throws Exception {
191+
Object fieldValue = document.getFieldValue(field, Object.class);
191192
if (addToRoot) {
192-
Object value = apply(document.getFieldValue(field, Object.class), allowDuplicateKeys, strictJsonParsing);
193+
Object value = apply(fieldValue, allowDuplicateKeys, strictJsonParsing);
193194
mergeParsedJson(document.getSourceAndMetadata(), value, addToRootConflictStrategy);
194195
} else {
195-
document.setFieldValue(targetField, apply(document.getFieldValue(field, Object.class), allowDuplicateKeys, strictJsonParsing));
196+
document.setFieldValue(targetField, apply(fieldValue, allowDuplicateKeys, strictJsonParsing));
196197
}
197198
return document;
198199
}

0 commit comments

Comments
 (0)