如何使用等待通知处理器? [英] How to use wait otify Processor?

问题描述

我正在运行 nifi 实例 1.2.0.

I have running nifi instance 1.2.0.

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

I just tried to use "WaitNotify" 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.

处理StandardFlowFileRecord时无法与缓存通信[uuid=faab337f-034c-4137-a2f3-abb46f22b474,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1494485406343,-1]offset=0, length=7005603],offset=5280310,name=input.csv,size=1054261] 由于 java.net.ConnectException:连接被拒绝:连接:

我不知道这个错误是什么意思?

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.

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