0

私は NiFi を評価しており、基本的なワークフローを作成しました。ローカル ディレクトリをリッスンし、いくつかの変換を適用してから、フローを kafka に入れます。

エラートレース

09:46:35 UTC ERROR1b6ae25f-e517-47d9-90a2-103109a47b90  localhost:10084

PutKafka[id=1b6ae25f-e517-47d9-90a2-103109a47b90] Failed to process session due to org.apache.nifi.processor.exception.FlowFileHandlingException: 
StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420]): 
org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420])

私のワークフローは次のようになります ここに画像の説明を入力

BasicFieldSplitProcessor は私のカスタム プロセッサで、ReplaceText の修正版です。

「フィールド分割キュー」の設定

  • FlowFile 有効期限情報:120 秒
  • バック プレッシャ オブジェクトのしきい値 Info:500000
  • バック プレッシャ データ サイズのしきい値情報: 200 MB
4

1 に答える 1

2

詳細を取得するためのすべての助けに感謝します。私たちは複製することができ、現在コミュニティのメンバーが解決に取り組んでいます。今のところ、実行期間を 0 秒に設定するだけで、より良い動作を確認できると考えています。確認してください。 https://issues.apache.org/jira/browse/NIFI-1534

于 2016-02-19T21:30:52.170 に答える