Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]

Support Questions

Find answers, ask questions, and share your expertise
Announcements
Share your experience with Cloudera on G2 and get a $25 Amazon Gift card.
Hi, I'm CLEO! Something exciting is coming to the Community. Stay Tuned!

How to use Notify and Wait in Apache Nifi version 2.0.0

avatar
Explorer

I am facing an issue with Notify and Wait starting from version 2.0.0. In order for them to listen to each other in version 1.28, I need to configure them with the MapCacheClientService 2.0.0 and MapCacheServer 2.0.0 services. However, in version 2.0.0, although I can still find both services in the documentation, in practice, the configuration only includes the MapCacheClientService 2.0.0 service, and I can no longer find the MapCacheServer 2.0.0 service.

DuyChan_0-1733304440018.png

Using Wait and Notify in version 2.0.0 seems much more difficult compared to previous versions. I spent two days trying to figure it out, but I haven't made any progress. If possible, could you please guide me on the correct configuration so that Wait and Notify can work properly, like they did in the older versions?

1 ACCEPTED SOLUTION

avatar
Explorer

@SAMSAL MapCacheClientService provides the ability to communicate with a MapCacheServer. I can find MapCacheServer in Add Controller Service

DuyChan_0-1733395091145.png

It seems like I have found a solution to my issue.

Thank you

View solution in original post

2 REPLIES 2

avatar
Super Guru

Hi @DuyChan ,

Have you tried using DistributedMapCacheClientService & DistributedMapCacheClientServer instead. Im not sure what is the difference with the MapCacheClientService but it should do the same job. Also be aware because of size limitation Nifi is not being published with all packages and in case you dont find services or processors that should be part of nifi , you probably need to download jar\nar pacakge from maven repositories and save to the Nifi Lib Folder:

https://mvnrepository.com/artifact/org.apache.nifi/nifi-hazelcast-services-api-nar/2.0.0

https://mvnrepository.com/artifact/org.apache.nifi/nifi-distributed-cache-client-service-api

If that helps please accept the solution.

Thanks

 

avatar
Explorer

@SAMSAL MapCacheClientService provides the ability to communicate with a MapCacheServer. I can find MapCacheServer in Add Controller Service

DuyChan_0-1733395091145.png

It seems like I have found a solution to my issue.

Thank you