- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Using wait Processor in nifi
- Labels:
-
Apache NiFi
Created on ‎08-20-2017 01:54 PM - edited ‎08-17-2019 06:42 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
I need to use wait processor for terminating invokehttp processor in case of failure, I have tried this - [https://stackoverflow.com/questions/43915412/how-to-use-wait-notify-processor][1]
and added DistributeCashMapServerService by PutDistributeMapCachProcessor (I have made host:localhost with port 4557 for both DistributeMapCachclient and server service), but both of them still throws execpetion:Should I change server port? Or configure it another way?
(P.S I have uploaded picture of error itself and my workflow in nifi)
Created on ‎08-20-2017 08:35 PM - edited ‎08-17-2019 06:41 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
The Wait processor works with the Notify processor.
The configuration of the Wait processor:
Here is the configuration of the Notify processor that will be a trigger for the Wait processor:
Here are the DistributedMapCacheClientService and DistributedMapCacheServer controller services being used by these processors and their configurations.
DistributedMapCacheServer
DistributedMapCacheClientService
It is better to put the actual hostname instead of just localhost.
The DistributedMapCacheClientService controller service needs to have a DistributedMapCacheServer controller service configured.
Replace the PutDistributedMapCache processor with the Notify processor in your flow.
Created ‎08-21-2017 08:48 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
I have successfully implemented all this (thank you for your answer) but it seems that it isn't good solution for my task,can you recommend me any internal command which can help me stopping another processor by compilig script in executescript processor
Created ‎08-21-2017 06:26 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
How can i add DistributedCashMapServer without putDistributedMap processor? why did you replace localhots withnifi-sme-19 ?
Created ‎08-21-2017 07:52 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
I have manged it already, can i stop other processor by 'wait' conection?
Created ‎08-21-2017 03:21 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
If that is how you want to use it, sure.
Created ‎08-21-2017 04:17 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
In this question, I provided an example of a script that will stop a processor. Stop a processor with a script
Won't this work for you?
Created ‎08-21-2017 05:51 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
I have windows and when i try to make it with bat file i get this errod https://community.hortonworks.com/questions/129851/stopping-processor-by-curl-commands.html
Created ‎08-21-2017 06:12 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
but it was useful, becuase tanks to it i found out how to make my task , but i still gave exceptions
Created ‎08-21-2017 05:49 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
first of all i have winsows and when i try to make all this by bat file i get this case :https://community.hortonworks.com/questions/129851/stopping-processor-by-curl-commands.html
