You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tk...@apache.org on 2015/11/22 02:22:57 UTC
[2/2] nifi git commit: NIFI-1196 Correcting treatment of FETCH events
as a continuation of a lineage trail and not the start of a new one.
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 (tkurc@apache.org)
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/master
Commit: 1580edb558e96dc49a40b50e8f5fd7e31e61371d
Parents: cdd2c4f
Author: Aldrin Piri <al...@apache.org>
Authored: Sat Nov 21 17:59:34 2015 -0500
Committer: Tony Kurc <tr...@gmail.com>
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