nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jsk...@apache.org
Subject nifi git commit: NIFI-3424: NIFI-3040: Fixed bug where we were generating a RepositoryRecord with an 'UPDATE' type instead of a 'CREATE' time for Replay of FlowFiles. This caused FlowFile to have no attributes when restored from the FlowFile Repository.
Date Thu, 02 Feb 2017 19:52:22 GMT
Repository: nifi
Updated Branches:
  refs/heads/0.x 008bffd9c -> 2276c6ac1


NIFI-3424: NIFI-3040: Fixed bug where we were generating a RepositoryRecord with an 'UPDATE'
type instead of a 'CREATE' time for Replay of FlowFiles. This caused FlowFile to have no attributes
when restored from the FlowFile Repository.

Signed-off-by: Joe Skora <jskora@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2276c6ac
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2276c6ac
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2276c6ac

Branch: refs/heads/0.x
Commit: 2276c6ac1c7f43ec75f0ae442c68506492034c22
Parents: 008bffd
Author: Mark Payne <markap14@hotmail.com>
Authored: Tue Nov 15 12:59:02 2016 -0500
Committer: Joe Skora <jskora@apache.org>
Committed: Thu Feb 2 19:50:57 2017 +0000

----------------------------------------------------------------------
 .../src/main/java/org/apache/nifi/controller/FlowController.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/2276c6ac/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
index 0895006..4559706 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
@@ -3628,7 +3628,8 @@ public class FlowController implements EventAccess, ControllerServiceProvider,
R
         provenanceEventRepository.registerEvent(replayEvent);
 
         // Update the FlowFile Repository to indicate that we have added the FlowFile to
the flow
-        final StandardRepositoryRecord record = new StandardRepositoryRecord(queue, flowFileRecord);
+        final StandardRepositoryRecord record = new StandardRepositoryRecord(queue);
+        record.setWorking(flowFileRecord);
         record.setDestination(queue);
         flowFileRepository.updateRepository(Collections.<RepositoryRecord> singleton(record));
 


Mime
View raw message