2017-05-11 35 views
0

私はnifiインスタンス1.2.0を実行しています。wait notify Processorの使い方は?

私はちょうどキャンバス内の参照 http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

ドラッグテンプレートを次のようにプロセッサ「を通知\待って」と私はそれを実行してみて使用しようとしました。

"Wait/Notify"プロセッサで次のエラーが表示されます。

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にパッチを適用し、何も私が見逃していた場合にどちらかといえば、それは

私を停止してください試していないのですか?

これを解決するために私を導きます。

答えて

2

DistributedMapCacheServerおよびDistributedMapCacheClientを作成して開始する必要があります。クライアントは、サーバーが待機しているポートとホストを使用して構成する必要があります。

次に、WaitおよびNotifyプロセッサはDistributedMapCacheClientを使用します。

プロセッサを起動することができたため、すでにクライアントの設定が行われている可能性がありますが、サーバーは実行されていません。

+0

ありがとうブライアンそれは働いた。 –

+0

@Bryan Bende - 待機関係をループしてWaitプロセッサに戻すか、待機するフローファイルを自動的に終了する予定ですか? – Dan

+0

@Danループを自己に戻すことで、リリースする必要があるかどうかを確認し続けることができます。通知が発生すると、待機中のフローファイルは待機プロセッサの成功関係を通過します。 –

関連する問題