I have a usecase which involves creating a new Record(actually several records) from a record in input flowfile, and writing it in output flowfile. PS: I would use avro reader to read input and avro writer to write into output. What is idiomatic way of doing it in nifi? ... View more

I have a nifi flow. I observe that if input file is split into smaller files and fed into the flow one by one, then overall time taken(sum of time taken for individual files) is considerably low compared to when I feed single big file. What can be a possible cause for this performance difference? Note: Flow has many processors that use avro readers/writers. I calculate time using following in a LogMessage processor: ${now():toNumber():minus(${lineageStartDate}):format("HH:mm:‌​ss", "GMT")} ... View more

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