Thank you for your answer, The second hash is performed after a PutHDFS and not a ListHDFS (I have edited my post, sorry for the mistake). If I understand you well, this check is not useful because PutHDFS and FetchFile processors are already able to catch corruption errors reliably? I would compare both hashes with NiFi expression language (:equals function) inside a RouteOnAttribute processor. ... View more

@mattclarke I'm having the same problem using "ScrollElasticSearchHttp" processor. Processor state shows one or more nodes of cluster, depending on situation, even when I've configured to "Primary Node only". Flowfiles have been duplicated on each added node. How can I solve the problem? ... View more