This commit is contained in:
joewitt 2015-06-04 13:49:38 -04:00
commit 8201381c9b
1 changed files with 0 additions and 2 deletions

View File

@ -193,8 +193,6 @@ public class SplitJson extends AbstractJsonPathProcessor {
segments.add(split); segments.add(split);
} }
processSession.getProvenanceReporter().fork(original, segments);
processSession.transfer(segments, REL_SPLIT); processSession.transfer(segments, REL_SPLIT);
processSession.transfer(original, REL_ORIGINAL); processSession.transfer(original, REL_ORIGINAL);
logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()}); logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()});