Re: How to use wait\notify Processor?

2017-05-11 Thread 尹文才
Hi, I think you need to first setup the distributed cache service to make
wait/notify processors work because wait/notify makes use of it to store
signals.

Regards,

Ben

2017-05-11 20:29 GMT+08:00 prabhu Mahendran <prabhuu161...@gmail.com>:

> favorite
> <http://stackoverflow.com/questions/43915412/how-to-use-wait-notify-processor#>
>
> I have running nifi instance 1.2.0.
>
> I just tried to use "Wait\Notify" Processor with following reference
> http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-
> mergecontent-dont-suffice
>
> Drag the template in canvas and i try to running it.
>
> Canvas shows following error in *"Wait/Notify"* processor.
>
> Unable to communicate with cache when processing
> StandardFlowFileRecord[uuid=faab337f-034c-4137-a2f3-abb46f22b474,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1494485406343-1,
> container=default, section=1], offset=0, length=7005603],offset=
> 5280310,name=input.csv,size=1054261] due to java.net.ConnectException:
> Connection refused: connect:
>
> I don't know what this error says?
>
> I am not apply any patches in 1.2.0 i just download binary file and tried
> it
>
> Please stop me if anything if anything i'm missed?
>
> And any one guide me to solve this.
>


How to use wait\notify Processor?

2017-05-11 Thread prabhu Mahendran
favorite
<http://stackoverflow.com/questions/43915412/how-to-use-wait-notify-processor#>

I have running nifi instance 1.2.0.

I just tried to use "Wait\Notify" Processor with following reference
http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

Drag the template in canvas and i try to running it.

Canvas shows following error in *"Wait/Notify"* processor.

Unable to communicate with cache when processing
StandardFlowFileRecord[uuid=faab337f-034c-4137-a2f3-abb46f22b474,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1494485406343-1, container=default,
section=1], offset=0,
length=7005603],offset=5280310,name=input.csv,size=1054261] due to
java.net.ConnectException: Connection refused: connect:

I don't know what this error says?

I am not apply any patches in 1.2.0 i just download binary file and tried it

Please stop me if anything if anything i'm missed?

And any one guide me to solve this.