Fixed reporting task bug
@@ -424,10 +424,8 @@ public class KyloProvenanceEventReportingTask extends AbstractReportingTask {
* @param eventId the eventId to save
*/
protected void setLastEventId(long eventId) throws IOException {
- if (eventId > 0) {
setLastEventId(stateManager, eventId);
}
- }
/**
* Call out to Kylo to sync the Flow Cache in the reporting task with that in Kylo. This will ensure prior to running through Provenance Events that the processorIds are in sync with the latest
