This is an automated email from the ASF dual-hosted git repository.
joewitt 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 c4ccd5f NIFI-6750: This closes #3810. add FETCH provenance event to
FetchFile
c4ccd5f is described below
commit c4ccd5f5054312c5b429be896bd35b5bea5ba143
Author: Mark Bean <[email protected]>
AuthorDate: Thu Oct 10 20:24:06 2019 +0000
NIFI-6750: This closes #3810. add FETCH provenance event to FetchFile
Signed-off-by: Joe Witt <[email protected]>
---
.../src/main/java/org/apache/nifi/processors/standard/FetchFile.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/FetchFile.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchFile.java
index b929f07..edd9585 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchFile.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchFile.java
@@ -272,7 +272,7 @@ public class FetchFile extends AbstractProcessor {
return;
}
- session.getProvenanceReporter().modifyContent(flowFile, "Replaced
content of FlowFile with contents of " + file.toURI(),
stopWatch.getElapsed(TimeUnit.MILLISECONDS));
+ session.getProvenanceReporter().fetch(flowFile,
file.toURI().toString(), "Replaced content of FlowFile with contents of " +
file.toURI(), stopWatch.getElapsed(TimeUnit.MILLISECONDS));
session.transfer(flowFile, REL_SUCCESS);
// It is critical that we commit the session before we perform the
Completion Strategy. Otherwise, we could have a case where we
