You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jg...@apache.org on 2022/01/13 15:59:21 UTC
[nifi] branch main updated: NIFI-9545 - Fix in-place replacement for LookupRecord processor
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 <pi...@gmail.com>
AuthorDate: Thu Jan 6 17:28:27 2022 +0100
NIFI-9545 - Fix in-place replacement for LookupRecord processor
Signed-off-by: Joe Gresock <jg...@gmail.com>
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);