NIFI конвертировать AVR в JSON, получая только одну запись - PullRequest
Новая
       6

NIFI конвертировать AVR в JSON, получая только одну запись

0 голосов
/ 26 апреля 2019

Я использую Nifi 1.8 и пробую простой рабочий процесс

GenerateFlowFile -> ConvertRecord -> ConvertAvroToJSON

Сгенерированный файл потока содержит 5 строк, но в выводе о происхождении данных представления в ConvertAvroToJSON показанотолько одна строка

Это ожидаемое поведение или я допустил ошибку?

Мой исходный файл в рабочем процессе создания: 

1,Millard,McKinley
2,Warren,Hoover
3,Dwight,Kennedy
4,Martin,Ford
5,Martin,Roosevelt

В записи преобразования я использую CSVRecordreader, используя$ {avro.schema} cvsreader_properties

a AvrRecordSetWriter, использующий $ {avro.schema} свойства записи набора записей avro

моя переменная avro.schema определяетСледующая схема: 

{
  "type": "record",
  "name": "LongList",
  "fields" : [
    {"name": "id", "type": "long"},
    {"name": "firstname", "type": "string"},
    {"name": "lastname", "type": "string"}
  ]
}

Я повторно использую тот же текст схемы в моем процессоре ConvertAvroToJson

схема avrotojson

Я ожидаю получить 5 строкв выводе моего конвейера (вывод заявки avrotojson)

Однако я получаю только первую строку: [{"id": 1, "firstname": "Millard", "lastname": "McKinley"}]

СделалЧто-то не так?Это ожидаемое поведение?

Один обходной путь для каждой строки перед раздачей, но есть ли способ обойтись без разбиения?

Спасибо

...