Hello, How can I verify that the sftp file has finished copying? because listSFTP processor is listenning, but some files do not complete because they have many megabytes and the fetchsftp processor captures it before the transfer ends. Thanks ... View more

Hello, i need use fetchHDF processor in the middle of the flow. I use first updateAttribute before fetchHDFS to create variable path and filename, but my problem is that i need to take all the files in a folder and i don't know how do it. updateattribute.jpg ... View more

Hi, I need create groovy script to count th fileflows, this is my script: def trigger = session.get() def flowFiles = session.get() if(flowFiles.size() < 9) { session.transfer(flowFiles,REL_SUCCESS) }else { session.transfer(flowFiles, REL_FAILURE) } I want launch a script if de fileflow files are < 9. But the error is: ... View more

Hello, i need execute a spark job from NiFi. The file .jar is in HDFS and i need know if the job finish success or fail. What is the best option? it's possible launch spark-submit command and receive the status? Thanks ... View more