如何使用wait \ notify处理器? [英] How to use wait\notify Processor?

问题描述

我正在运行nifi实例1.2.0.

I have running nifi instance 1.2.0.

我只是尝试通过以下参考使用等待\通知"处理器 http://ijokarumawak .github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

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.

它在等待/通知" 处理器中显示以下错误.

It 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?

我没有在1.2.0中应用任何补丁，我只是下载二进制文件并尝试了

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 guide me to solve this.

推荐答案

您将需要创建并启动DistributedMapCacheServer和DistributedMapCacheClient.客户端需要配置服务器正在侦听的端口和主机.

You will need to create and start a DistributedMapCacheServer and DistributedMapCacheClient. The client needs to be configured with the port and host that the server is listening on.

然后，等待"和通知"处理器使用DistributedMapCacheClient.

Then the Wait and Notify processors use the DistributedMapCacheClient.

由于您能够启动处理器，因此您可能已经安装了客户端，但是没有运行服务器.

Since you were able to start the processors, you likely already have the client setup, but you don't have the server running.

这篇关于如何使用wait \ notify处理器?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！