Hi @Wynner, i am running on 1.1 and i fixed these 2 issues.. fixed the Kerberos error by using only one Kerberos principal across many connections, earlier i used some connections as NiFi and some as my id..i think it was getting confused some where and throwing errors..once i changed all to use nifi id it is working fine. Only way i could clear hung processes are changing a setting in Ambari to not to pick the files when nifi restarts and restarting NiFi. i couldn't find anyother way.. Regards, Sai ... View more

@Bilel Boubakri I am assuming you know how many subdirectories there are in this solution. ListFTP - scanning the main directory with all the subdirectories EexcutScript - running a groovy script waiting for all of the flag.ok files to be in the subdirectories FetchFTP - configured to pull the wanted files Here is a snapshot of the simple flow: Here is the sample groovy script for the ExecuteScript processor, configured for this example to wait for 5 files: def flowFiles = session.get(5) if(!flowFiles || flowFiles.size() < 5) { session.rollback() } else { session.transfer(flowFiles, REL_SUCCESS) } waiting-for-5-files-before-ftping-the-files.xml Here is a template of the sample flow ... View more