nifi detect duplicate MapCacheServer Error

[#1]

I have configured a DistributedMapCacheClientService and a DistributedMapCacheServer which are used by the DetectDuplicate processor. But when I try to process flowfiles using the DetectDuplicate Processor I receive an error: "Detect Duplicate failed to process session due to java.nio.channels.UnresolvedAdressException". So is there any additional configuration needed? Btw, I have installed Nifi additionally on my Hortonworks Sandbox, which is running locally.

[#2]

Hi @Alexander Flick,

Could you share the configuration of your controller services? Are the two controller services running?

[#3]

MapCacheServer:

MapCacheClientService:

Both Controller Services are enabled but how can I check that they are running?

[#4 · Accepted solution]

Since you are running on a standalone NiFi instance, the MapCacheServer is running locally, then you should put 'localhost' for the property 'Server Hostname' in the client service. Let me know if it helps.

[#5]

Yes, that helped - it works 🙂 Thank you so much!

[#6]

@Pierre Villard

In the cluster mode, if we run MapCacheServer on only NCM, does that mean once NCM fails, the MapCacheServer becomes unavailable?

Is there anyway to avoid it?

Thanks.

[#7]

@Alvin Ji,

This is correct with NiFi 0.x. Unless you implement your own MapCacheServer service and separate it from NiFi, I am not sure there is a solution.

With NiFi 1.x (first version to be released in coming days, RC vote in progress), this is solved with a zero-master clustering paradigm.