Repository: incubator-nifi Updated Branches: refs/heads/develop e2227cdaf -> 8f55e35a0
nifi-643: Removing duplicate provenance FORK event in SplitJson for generated files. Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/88bfa664 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/88bfa664 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/88bfa664 Branch: refs/heads/develop Commit: 88bfa664dc0986be3987b685fe65d7fb0e114870 Parents: 8980167 Author: Aldrin Piri <[email protected]> Authored: Tue Jun 2 15:18:16 2015 -0400 Committer: Aldrin Piri <[email protected]> Committed: Tue Jun 2 15:29:52 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/standard/SplitJson.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/88bfa664/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java index ef7a86a..a3a4ed8 100644 --- a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java +++ b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java @@ -193,8 +193,6 @@ public class SplitJson extends AbstractJsonPathProcessor { segments.add(split); } - processSession.getProvenanceReporter().fork(original, segments); - processSession.transfer(segments, REL_SPLIT); processSession.transfer(original, REL_ORIGINAL); logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()});
