I'm testing a simple List/Fetch setup on a 3 node cluster. I created a
DistributedMapCacheServer controller service with the default settings (no
SSL) and then created a DistributedMapCacheClientService that points at one
of the cluster hostnames. The ListSFTP processor is set to use the
Distributed Cache Service that I created.

The ListSFTP processor lists the same 100 source files from the remote
system on each node, and sends 300 Flow Files downstream to the FetchSFTP
processor. I thought that the map cache allowed the cluster nodes to
determine which files had already been listed by other cluster nodes...
maybe I'm missing something.

Any assistance is appreciated.

NiFi version 1.0.0 in HDF 2.0.1


-Nick

Reply via email to