On a processor, right click -> view status history....there is a data available by name 'Records Processed' in dropdown. For one of the processor in my flow, this is not available. What can be the reason for this? Is it possible that value was so high that system lost track somewhere? ... View more

I have a nifi flow, working fine.  It picks file from a source directory, processes it, and file is deleted from source directory once picked up. This all works fine first time. But later on, if I copy another file in source directory, that file is not picked up. I even stop all processors, clean any queue if not empty, and restart processors, but still file is not picked from input directory. What causes this behaviour? As a result, I have to stop-restart nifi, making it a bit cumbersome. PS: Based on some google suggestions, I tried to delete flowfile_repository, but it doesn't allow so with message 'Device or resource busy'. ... View more

I have some basic questions about nifi cluster. I understand that nifi makes use of multiple nodes to speed up the processing of data. But how do we ensure durability of data processed? Suppose we distribute n flowfiles in a queue to several nodes, with each node getting a subset of n files. Does nifi assign same subset to more than one nodes, so that if one of those processing node goes down, we still have others working on same subset? Second, how is result of processing  done on different nodes aggregated? Is it done on primary node OR there is some other mechanism? ... View more

What does this message mean on an invalid processor: I see it for processor FetchXMLFile. On scheduling tab, execution dropdown has 'Primary Node' selected. On changing it to 'All Nodes', error goes away. I am on 1.22.0(with some nars from 1.10.0 also added to lib folder). ... View more