This is an automated email from the ASF dual-hosted git repository.
jgresock pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new d1599ee NIFI-9545 - Fix in-place replacement for LookupRecord
processor
d1599ee is described below
commit d1599eebcf312c4be1cb9427646875698d8bff35
Author: Pierre Villard <[email protected]>
AuthorDate: Thu Jan 6 17:28:27 2022 +0100
NIFI-9545 - Fix in-place replacement for LookupRecord processor
Signed-off-by: Joe Gresock <[email protected]>
This closes #5637.
---
.../src/main/java/org/apache/nifi/processors/standard/LookupRecord.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
index 0132cd8..1f873a5 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
@@ -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) {
final Map<String, RecordPath> recordPaths = flowFileContext.getKey();
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()) {
- final String coordinateKey = entry.getKey();
final RecordPath recordPath = entry.getValue();
final RecordPathResult pathResult = recordPath.evaluate(record);
