That's perfect ! ... View more

Hi @Shu_ashu, @ramesh_ganginen  I am encountering the same issue. I attempted the method you suggested, but it didn't work. I'm trying to copy a table from my MySQL database to my local machine using Apache NiFi. I've configured the 'ConvertRecord' processor and added the 'CSVRecordSetWriter', but I'm still receiving files in JSON format. Can you please guide me if I'm making any mistakes? ... View more

Hi @marco21  can you please provide me the full implementation code for ListDynamiscSFTP that you have mentioned in your post. I do have the same requirement but not able to determine the methods that I have to override to get the exact implementation of ListSFTP  ... View more

Thanks ... View more

Your original example had everything at +0000 but the error has +0700 so perhaps change the pattern to  yyyy-MM-dd'T'HH:mm:ssZ ... View more

have you a response on your issue please? ... View more

@jricogar  Why not use the listHDFS processor? It retains state so that same HDFS files do not get listed multiple times. Just trying to understand your use case for using FetchHDFS without ListHDFS processor. Thanks, Matt ... View more

I understand that it'd be pointless to send a FlowFile to the ListS3 processor, but it still seems like we should be able to attach it to a Wait processor and have it trigger that way. ... View more

This is not working for spark on hive.    no applicaiton id found when grep query id. ... View more

You can use EvaluateJsonPath. You only have to add an extra attribute and name it as you want (e.g. count) and set as value "$.my.array.size.length()". Then select Destination and change it to flowfile-attribute. This processor will produce a flowfile which has your extra attribute ... View more