問題タブ [hortonworks-dataflow]

Kafkaトピックで約2000000のメッセージがあり、NiFiを使用してこれらのレコードをHDFSに入れたいので、これにPutHDFSプロセッサを使用してConsumeKafka_0_10いますが、HDFSに小さなファイルが生成されるため、レコードをマージするためにMerge Contentプロセッサを使用していますファイルをプッシュする前に。 設定の変更が必要な場合は助けてください これは少数のメッセージには問題なく機能しますが、大量のデータを含むトピックに関しては、レコードごとに 1 つのファイルを書き込みます。

ありがとうございました！！

私はGenerateFlowFileプロセッサを頻繁に使用して、他のプロセッサの動作をテストし、フローを理解しています。しかし、毎回、デフォルトで「0」であるデフォルトの「実行スケジュール」を変更するのを忘れています。そして、気が付く前に、何千ものファイルでフローを攻撃しています。

デフォルト値を変更する方法はありますか? 時々本当にイライラします。

テストと開発を迅速に行うために、プロセッサの右上隅から Bulletin をクリアする方法があると非常に便利です。エラーが表示されて修正したら、再起動する前にクリアしたいと思います。

現在のバージョンで可能な場合は、ご案内ください。