如何使用wait \ notify處理器？

我只是試圖用「等待\通知」處理器，具有下列參考 http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

將模板在畫布上的，我嘗試運行它。

它在「等待/通知」處理器中顯示以下錯誤。

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:

我不知道這是什麼錯誤說？

我不是在1.2.0適用任何修補我剛下載的二進制文件，並嘗試了

請叫我停下來什麼，如果我什麼我錯過了什麼？

並指導我解決這個問題。

來源

2017-05-11 Mahendra prabhu

您將需要創建並啓動DistributedMapCacheServer和DistributedMapCacheClient。客戶端需要配置服務器正在監聽的端口和主機。

然後Wait和Notify處理器使用DistributedMapCacheClient。

由於您能夠啓動處理器，您可能已經擁有客戶端設置，但您沒有運行服務器。

來源

2017-05-11 13:41:11

感謝布賴恩它的工作。 –

@Bryan Bende - 我們是否應該將等待關係循環回Wait處理器或自動終止流文件等待？ – Dan

@Dan循環回自己，以便它可以繼續檢查是否應該釋放，一旦通知發生，等待的流文件將通過等待處理器的成功關係 –

如何使用wait \ notify處理器？

回答

相關問題