[nifi] branch master updated: Fiz writeBatch to avoid cycle in provenance graph

[mthomsen]

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

mthomsen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new 57947cd  Fiz writeBatch to avoid cycle in provenance graph
     new a33a5e3  Merge pull request #4119 from eduardofontes/patch-4
57947cd is described below

commit 57947cd2a205a522b3d929fde8c0cf102a7a59c6
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);
     }