[ https://issues.apache.org/jira/browse/NIFI-4752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16319896#comment-16319896 ]
ASF GitHub Bot commented on NIFI-4752: -------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/nifi/pull/2390 > REPLAY events returned by WriteAheadProvenanceRepository have child FlowFile > UUID as event FlowFile UUID > -------------------------------------------------------------------------------------------------------- > > Key: NIFI-4752 > URL: https://issues.apache.org/jira/browse/NIFI-4752 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Affects Versions: 1.4.0 > Reporter: Koji Kawamura > Assignee: Mark Payne > > The ['Provenance Events' > documentation|https://nifi.apache.org/docs/nifi-docs/html/developer-guide.html#provenance_events] > describes about REPLAY event as follows: > {quote} > Indicates a provenance event for replaying a FlowFile. The UUID of the event > indicates the UUID of the original FlowFile that is being replayed. The event > contains one Parent UUID that is also the UUID of the FlowFile that is being > replayed and one Child UUID that is the UUID of the a newly created FlowFile > that will be re-queued for processing > {quote} > The default PersistentProvenanceRepository behaves as written in the doc. But > WriteAheadProvenanceRepository returns REPLAY events having Child UUID as its > FlowFile UUID instead. > Here is the lines of code that set FlowFile UUID for the provenance events. > https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/schema/LookupTableEventRecord.java#L276-L280 > {code} > String uuid = updatedAttributes == null ? null : > updatedAttributes.get(CoreAttributes.UUID.key()); > if (uuid == null) { > uuid = previousAttributes == null ? null : > previousAttributes.get(CoreAttributes.UUID.key()); > } > builder.setFlowFileUUID(uuid); > {code} > WriteAheadProvenanceRepository does not seem to have 'FlowFile UUID' value > persisted, which is set by FlowController when replay events are registered. > Instead, WriteAheadProvenanceRepository fill 'FlowFile UUID' from updated or > previous 'UUID' attribute. -- This message was sent by Atlassian JIRA (v6.4.14#64029)