Created 10-05-2017 06:41 PM
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
Created on 10-05-2017 08:23 PM - edited 08-17-2019 09:24 PM
Resolved by changing the ConvertAvroToJSON JSON container options to none instead of array.
Created on 10-05-2017 07:16 PM - edited 08-17-2019 09:25 PM
I have tried to modify the configuration for InferAvroSchema
I have "Schemas for JSON files should be record" error message for ConvertJSONtoAvro
Created on 10-05-2017 08:23 PM - edited 08-17-2019 09:24 PM
Resolved by changing the ConvertAvroToJSON JSON container options to none instead of array.