You have 100 flow files? Perhaps you can use wait and notify processors and release 1 flow file each time. If query is successfull then signal to release fliw file to perform next query, if not then signal to release to failure using route on attribute processor which will come after the wait processor. Something similar to this sample: https://gist.github.com/ijokarumawak/375915c45071c7cbfddd34d5032c8e90 ... View more

When did this error occured? Did something happened? For example you made a change in the consumer processor topic or group id? ... View more

@Doug Lennings did you manage to make it work? can you post an example? ... View more

Thanks for the anwer @Bryan Bende, Are you saying that there are processors that just dont produce data provenance at all? Why dont all the processors produce provenance events? Can you give an example? Is it an option that there isnt any more space for more provenance data to be created in the NIFI cluster so some processors will create provenance and others will not just randomly or something like that? For example FetchHBaseRow processor should produce provenance event always? ... View more