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 <[email protected]> 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 <[email protected]> Authored: Tue Nov 15 12:59:02 2016 -0500 Committer: Joe Skora <[email protected]> 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));
