NiFi：入力フローファイルをAvroファイルとして読み取ることはできません。

Question

NiFi 1.4からはじまったばかりです。

パイプ区切りのメッセージをkafka経由でHiveに送信しようとしています。だから私はConsumeKafkaRecord_0_10とPutHivStreamingプロセッサを使用しています。カフカリーダーを消費して、成功したデータをPutHiveStreamingに送信します。

はアブロ形式でカフカリーダー書き込みデータを消費けどPutHiveStreamingは、着信フローファイルがアブロfileeとして読み取ることができません

としてエラーを与える：にjava.io.IOException：ないデータファイル」

Answer 1

PutHiveStreamingはアブロデータファイルを読むことができるので、あなたはConsumeKafkaRecordで使用されるライター組み込みスキーマに設定スキーマライトストラテジとAvroRecordSetWriterであることを確認する必要があります。

をスキーマはトンを埋め込まれていない場合それがHiveプロセッサに到達すると、有効なAvroデータファイルにはなりません。