This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 91f6b42 NIFI-8085 Use poll(Duration) in ConsumeKafka_2_x processors
add a73cd6a NIFI-7856: If a Provenance Event File is ready to be rolled
over due to the maximum amount of time having elapsed, avoid rolling over
unless there is at least one event written to the event file. Otherwise, we can
have multiple RecordWriters / RecordWriterLeases pointing to the same file.
This can result in data being overwritten, as well as failing to compress the
event file upon rollover. Also added significant DEBUG/TRACE level logging.
No new revisions were added by this update.
Summary of changes:
.../nifi/provenance/store/RecordWriterLease.java | 13 +++++++++--
.../provenance/store/WriteAheadStorePartition.java | 25 ++++++++++++++++++----
2 files changed, 32 insertions(+), 6 deletions(-)
