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

Merge pull request #4119 from eduardofontes/patch-4 

NIFI-7233 - Fix Mongo Processors to avoid cycle in provenance graph
This commit is contained in:
Mike 2020-03-08 13:18:12 -04:00 committed by GitHub
parent 0f775f3a57 57947cd2a2
commit a33a5e35b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
View File

@ -347,7 +347,9 @@ public abstract class AbstractMongoProcessor extends AbstractProcessor {
FlowFile flowFile = parent != null ? session.create(parent) : session.create();
flowFile = session.importFrom(new ByteArrayInputStream(payload.getBytes(charset)), flowFile);
flowFile = session.putAllAttributes(flowFile, extraAttributes);
session.getProvenanceReporter().receive(flowFile, getURI(context));
if (parent == null) {
session.getProvenanceReporter().receive(flowFile, getURI(context));
}
session.transfer(flowFile, rel);
}