Re: Nifi Parallel Execution

2018-04-12 Thread Eric Ulicny
We have attempted to use the distributed map cache with the Detect Duplicate processor as recommended to no avail. The first time two identical flowfiles are sent simultaneously they both make it through to the the non-duplicate relationship. After that point they will be appropriately detected.

Re: Nifi Parallel Execution

2018-04-10 Thread Bryan Bende
Hello, DetectDuplicate uses a DistributedMapCacheClientService which would be connecting to a DistributedMapCacheServer on one of your nodes. So all nodes should be connecting to the same cache server which is where the information about previously seen data is stored. -Bryan On Tue, Apr 10,

Nifi Parallel Execution

2018-04-10 Thread Eric Ulicny
Hello, We have a use case where we execute processors on all nodes but would like to use the detect duplicate processor to ensure records are unique. We are observing that we must run it on one node to truly detect duplicates. Is there any way to merge flowfiles from all running executors? -Eric