You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2017/08/11 01:13:55 UTC
nifi git commit: 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 intende
Repository: nifi
Updated Branches:
refs/heads/master ec0c8278b -> 96f5407ed
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.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/96f5407e
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/96f5407e
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/96f5407e
Branch: refs/heads/master
Commit: 96f5407ed9d1fca9a6975ddb5c93355343aa791c
Parents: ec0c827
Author: Mark Payne <ma...@hotmail.com>
Authored: Thu Aug 3 15:55:19 2017 -0400
Committer: joewitt <jo...@apache.org>
Committed: Thu Aug 10 18:13:28 2017 -0700
----------------------------------------------------------------------
.../apache/nifi/controller/repository/StandardProcessSession.java | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/96f5407e/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
index 6393014..0e2e9b5 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
@@ -1192,9 +1192,6 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
if (record == null) {
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