NIFI-1196 Correcting treatment of FETCH events as a continuation of a lineage trail and not the start of a new one.
Reviewed by Tony Kurc ([email protected]) Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1580edb5 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1580edb5 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1580edb5 Branch: refs/heads/NIFI-655 Commit: 1580edb558e96dc49a40b50e8f5fd7e31e61371d Parents: cdd2c4f Author: Aldrin Piri <[email protected]> Authored: Sat Nov 21 17:59:34 2015 -0500 Committer: Tony Kurc <[email protected]> Committed: Sat Nov 21 20:21:36 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/provenance/StandardLineageResult.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/1580edb5/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java ---------------------------------------------------------------------- diff --git a/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java b/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java index cf16fc0..02c089d 100644 --- a/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java +++ b/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java @@ -259,6 +259,7 @@ public class StandardLineageResult implements ComputeLineageResult { case FORK: case JOIN: case REPLAY: + case FETCH: case CLONE: { // For events that create FlowFile nodes, we need to create the FlowFile Nodes and associated Edges, as appropriate for (final String childUuid : record.getChildUuids()) { @@ -288,7 +289,6 @@ public class StandardLineageResult implements ComputeLineageResult { } break; case RECEIVE: - case FETCH: case CREATE: { // for a receive event, we want to create a FlowFile Node that represents the FlowFile received // and create an edge from the Receive Event to the FlowFile Node
