It looks like you have a correct event file, likely the result of the server suddenly restarting.
One option would be to delete the corrupt event file (though it's difficult to understand from that error message exactly which event file it's reading from). It would be possible to View State on the reporting task and then use that to determine which event file is being looked at (i think the reporting task stores state about the last event id that it has processed, and the event files are named based on the event ID, so you should be able to do some correlation there). Another option may be to clear the Reporting Tasks's state and set the "Start Position" property to "End of Stream." Unfortunately, though, that would mean that you would not be sending any Provenance Events between the point where the event file became corrupt and the current end of Provenance Events. On Nov 14, 2019, at 12:45 PM, Shawn Weeks <[email protected]<mailto:[email protected]>> wrote: There appears to be something in the NiFi Provenance that Site to Site Reporting doesn't like. Does anyone know a workaround for this as it quits sending updates when this happens. I'm on NiFi 1.9.2. Thanks Shawn 2019-11-14 11:42:50,627 ERROR [Timer-Driven Process Thread-11] o.a.n.r.SiteToSiteProvenanceReportingTask SiteToSiteProvenanceReportingTask[id=016e105d-8a46-124c-607f-3856d44bf13d] Failed to retrieve Provenance Events from repository due to: Failed to read field 'Component Type': java.io.IOException: Failed to read field 'Component Type' java.io.IOException: Failed to read field 'Component Type' at org.apache.nifi.repository.schema.SchemaRecordReader.readField(SchemaRecordReader.java:177) at org.apache.nifi.repository.schema.SchemaRecordReader.readInlineRecord(SchemaRecordReader.java:83) at org.apache.nifi.repository.schema.SchemaRecordReader.readRecord(SchemaRecordReader.java:75) at org.apache.nifi.provenance.EventIdFirstSchemaRecordReader.readRecord(EventIdFirstSchemaRecordReader.java:138) at org.apache.nifi.provenance.EventIdFirstSchemaRecordReader.nextRecord(EventIdFirstSchemaRecordReader.java:132) at org.apache.nifi.provenance.serialization.CompressableRecordReader.nextRecord(CompressableRecordReader.java:287) at org.apache.nifi.provenance.store.iterator.SequentialRecordReaderEventIterator.nextEvent(SequentialRecordReaderEventIterator.java:73) at org.apache.nifi.provenance.store.iterator.AuthorizingEventIterator.nextEvent(AuthorizingEventIterator.java:47) at org.apache.nifi.provenance.store.PartitionedEventStore.getEvents(PartitionedEventStore.java:214) at org.apache.nifi.provenance.store.PartitionedEventStore.getEvents(PartitionedEventStore.java:158) at org.apache.nifi.provenance.store.PartitionedEventStore.getEvents(PartitionedEventStore.java:148) at org.apache.nifi.provenance.WriteAheadProvenanceRepository.getEvents(WriteAheadProvenanceRepository.java:195) at org.apache.nifi.reporting.StandardEventAccess.getProvenanceEvents(StandardEventAccess.java:116) at org.apache.nifi.reporting.util.provenance.ProvenanceEventConsumer.consumeEvents(ProvenanceEventConsumer.java:203) at org.apache.nifi.reporting.SiteToSiteProvenanceReportingTask.onTrigger(SiteToSiteProvenanceReportingTask.java:300) at org.apache.nifi.controller.tasks.ReportingTaskWrapper.run(ReportingTaskWrapper.java:44) at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.io.IOException: Found a field of type '' but that was not in the expected list of types at org.apache.nifi.repository.schema.SchemaRecordReader.readFieldValue(SchemaRecordReader.java:240) at org.apache.nifi.repository.schema.SchemaRecordReader.readField(SchemaRecordReader.java:171) ... 23 common frames omitted
