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

NIFI-3329 This closes #2053. Removed check for latest version of flowfile when migrating flowfile from 1 session to another because we now longer are requiring latest version of flowfile be passed to session anywhere else. It was intended to be removed from StandardProcessSession.migrate when it was removed from StandardProcessSession.validateRecordState but it was overlooked.

This commit is contained in:
Mark Payne 2017-08-03 15:55:19 -04:00 committed by joewitt
parent ec0c8278b4
commit 96f5407ed9
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
View File

@ -1192,9 +1192,6 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
if (record == null) { if (record == null) {
throw new FlowFileHandlingException(flowFile + " is not known in this session (" + toString() + ")"); throw new FlowFileHandlingException(flowFile + " is not known in this session (" + toString() + ")");
} }
if (record.getCurrent() != flowFile) {
throw new FlowFileHandlingException(flowFile + " is not the most recent version of this FlowFile within this session (" + toString() + ")");
}
} }
// If we have a FORK event for one of the given FlowFiles, then all children must also be migrated. Otherwise, we // If we have a FORK event for one of the given FlowFiles, then all children must also be migrated. Otherwise, we