[Nifi] Basic JSON to AVRO Configuration Understanding

ken_hui — Fri, 06 Oct 2017 01:41:38 GMT

I try to understand how JSON to AVRO work.
I have a basic workflow - https://community.hortonworks.com/storage/attachments/39679-screen-shot-2017-10-05-at-113158-am.png

ExecuteSQL -> ConvertAvroToJSON -> InferAvroSchema -> ConvertJSONtoAvro -> PutAzureBlobStorage

I'm facing cannot find schema error.

https://community.hortonworks.com/storage/attachments/39680-screen-shot-2017-10-05-at-113455-am.png

I have not changed anything for InferAvroSchema.
I added ${inferred.avro.schema} in ConvertJSONtoAvro Record schema

I have also tried output the InferAvroSchema into a output and copy and paste it back to ConvertJSONtoAvro Record schema manually. Also, does not working.
Example:
{"type":"record","name":"NiFi_ExecuteSQL_Record","namespace":"any.data","fields":[ ... Key Value Pairs for name and type ]}

How can I convert JSON to Avro successfully

Re: [Nifi] Basic JSON to AVRO Configuration Understanding

ken_hui — Sun, 18 Aug 2019 04:25:12 GMT

I have tried to modify the configuration for InferAvroSchema

I have "Schemas for JSON files should be record" error message for ConvertJSONtoAvro

Re: [Nifi] Basic JSON to AVRO Configuration Understanding

ken_hui — Sun, 18 Aug 2019 04:24:58 GMT

Resolved by changing the ConvertAvroToJSON JSON container options to none instead of array.

question Re: [Nifi] Basic JSON to AVRO Configuration Understanding in Archives of Support Questions (Read Only)

[Nifi] Basic JSON to AVRO Configuration Understanding

Re: [Nifi] Basic JSON to AVRO Configuration Understanding

Re: [Nifi] Basic JSON to AVRO Configuration Understanding