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

NIFI-9545 - Fix in-place replacement for LookupRecord processor 

Signed-off-by: Joe Gresock <jgresock@gmail.com>

This closes #5637.
This commit is contained in:
Pierre Villard 2022-01-06 17:28:27 +01:00 committed by Joe Gresock
parent bc2ba9537a
commit d1599eebcf
No known key found for this signature in database
GPG Key ID: 37F5B9B6E258C8B7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
View File

@ -308,9 +308,9 @@ public class LookupRecord extends AbstractRouteRecord<Tuple<Map<String, RecordPa
private Set<Relationship> doInPlaceReplacement(Record record, FlowFile flowFile, ProcessContext context, Tuple<Map<String, RecordPath>, RecordPath> flowFileContext) { private Set<Relationship> doInPlaceReplacement(Record record, FlowFile flowFile, ProcessContext context, Tuple<Map<String, RecordPath>, RecordPath> flowFileContext) {
final Map<String, RecordPath> recordPaths = flowFileContext.getKey(); final Map<String, RecordPath> recordPaths = flowFileContext.getKey();
final Map<String, Object> lookupCoordinates = new HashMap<>(recordPaths.size()); final Map<String, Object> lookupCoordinates = new HashMap<>(recordPaths.size());
final String coordinateKey = lookupService.getRequiredKeys().iterator().next();
for (final Map.Entry<String, RecordPath> entry : recordPaths.entrySet()) { for (final Map.Entry<String, RecordPath> entry : recordPaths.entrySet()) {
final String coordinateKey = entry.getKey();
final RecordPath recordPath = entry.getValue(); final RecordPath recordPath = entry.getValue();
final RecordPathResult pathResult = recordPath.evaluate(record); final RecordPathResult pathResult = recordPath.evaluate(record);