Archives of Support Questions (Read Only)

johncarteratfl · ‎09-15-2017

I have a flow in which I wait for 5 files to come out from each of the respective executeProcessors, after which I start another processor. I achieved this using Wait and Notify processors by target signal count given as 5. I stop and restart the flow, it works as expected. Now, my question is when and how would this counter be reset? If the executeProcessors are scheduled to run for every 30 min, do signals from notify keep increasing the counter. If so, how does my wait processor ever match the signal count of 5 that I gave and proceed to next processor every time.

Thanks,

John

Wynner · ‎09-19-2017

@John Carter

Assuming you have the flow designed correctly.

You don't have to reset the counter. That is why the Wait/Notify use the DistributedMapCacheClientService. It will keep track of the signal count.

Would you be willing to provide a snapshot of your flow? Also, a snapshot of how the DistributedMapCacheServer controller service is configured.

View solution in original post

Wynner · ‎10-02-2017

@John Carter

Would you accept the answer so that others know it resolved your issue?

johncarteratfl · ‎10-02-2017

Hi Wyner, Yes, after i disabled and enabled the MapCahce service configuration, it was working fine. Thanks for that.

Cloudera Community

Archives of Support Questions (Read Only)

Reset of Target Signal Count in Wait Processor