[nifi] 23/47: Fiz writeBatch to avoid cycle in provenance graph

[joewitt]

This is an automated email from the ASF dual-hosted git repository.

joewitt pushed a commit to branch support/nifi-1.11.x
in repository https://gitbox.apache.org/repos/asf/nifi.git

commit ae8e75222729b8dfaa3ae11c285a9bae072efe6e
Author: Eduardo Fontes <eduardo.fon...@gmail.com>
AuthorDate: Fri Mar 6 16:06:21 2020 -0300

    Fiz writeBatch to avoid cycle in provenance graph
---
 .../org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
 
b/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
index 43c210c..df918d9 100644
--- 
a/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
+++ 
b/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
@@ -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);
     }