From a73ee10df5021f83a35b53eec71468da40f8cc5d Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Tue, 15 Nov 2016 12:59:02 -0500 Subject: [PATCH] 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. --- .../main/java/org/apache/nifi/controller/FlowController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 08950068f7d8..455970610ab4 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 ProvenanceEventRecord replayFlowFile(final ProvenanceEventRecord event, f 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. singleton(record));