From 96f5407ed9d1fca9a6975ddb5c93355343aa791c Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Thu, 3 Aug 2017 15:55:19 -0400 Subject: [PATCH] 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. --- .../nifi/controller/repository/StandardProcessSession.java | 3 --- 1 file changed, 3 deletions(-) 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 6393014bcb..0e2e9b5061 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