Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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)
This commit is contained in:
Aldrin Piri 2015-11-21 17:59:34 -05:00 committed by Tony Kurc
parent cdd2c4f22c
commit 1580edb558
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardLineageResult.java
View File

@ -259,6 +259,7 @@ public class StandardLineageResult implements ComputeLineageResult {
case FORK: case FORK:
case JOIN: case JOIN:
case REPLAY: case REPLAY:
case FETCH:
case CLONE: { case CLONE: {
// For events that create FlowFile nodes, we need to create the FlowFile Nodes and associated Edges, as appropriate // For events that create FlowFile nodes, we need to create the FlowFile Nodes and associated Edges, as appropriate
for (final String childUuid : record.getChildUuids()) { for (final String childUuid : record.getChildUuids()) {
@ -288,7 +289,6 @@ public class StandardLineageResult implements ComputeLineageResult {
} }
break; break;
case RECEIVE: case RECEIVE:
case FETCH:
case CREATE: { case CREATE: {
// for a receive event, we want to create a FlowFile Node that represents the FlowFile received // 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 // and create an edge from the Receive Event to the FlowFile Node