Skip to content

Commit fcdf307

Browse files
committed
NIFI-14861: Incorporated review comments
1 parent 8a71201 commit fcdf307

File tree

1 file changed

+1
-16
lines changed
  • nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph

1 file changed

+1
-16
lines changed

nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/EnrichGraphRecord.java

Lines changed: 1 addition & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -204,22 +204,7 @@ public void onScheduled(ProcessContext context) {
204204
private List<FieldValue> getRecordValue(Record record, RecordPath recordPath) {
205205
final RecordPathResult result = recordPath.evaluate(record);
206206
final List<FieldValue> values = result.getSelectedFields().toList();
207-
if (!values.isEmpty()) {
208-
if (values.size() == 1) {
209-
FieldValue fieldValue = values.get(0);
210-
Object raw = fieldValue.getValue();
211-
212-
if (raw != null && raw.getClass().isArray()) {
213-
return Collections.emptyList();
214-
}
215-
216-
return List.of(fieldValue);
217-
} else {
218-
return values;
219-
}
220-
} else {
221-
return null;
222-
}
207+
return values.isEmpty() ? null : values;
223208
}
224209

225210
@Override

0 commit comments

Comments
 (0)