Hello Group/ Bryan,
Anshu here.
While trying the "*ConvertJSONToAvro*" processor, I came across the
following issue. I am not sure whether it is correct or not though.
So I have this input JSON file which might contain one or more valid/
invalid JSON records. Need to use this processor to convert them into Avro
format before I write and process them onto HDFS.
However strangely in the output FlowFile, I am getting only 1 record
converted (last valid JSON record is only getting converted).
Following "*Record Schem*a" I am using for this purpose.
*{"type": "record",*
* "name": "ClickData",*
* "fields": [*
* {"name": "SuperShopId", "type": ["string", "null"]},*
* {"name": "LinkId", "type": ["string", "null"]},*
* {"name": "ClickId", "type": ["string", "null"]}, *
* {"name": "VisitorId", "type": ["string", "null"]},*
* {"name": "RawHTTPRequest", "type": ["string", "null"]},*
* {"name": "RequestTimestamp", "type": "long"},*
* {"name": "RedirectURL", "type": ["string", "null"]},*
* {"name": "ResponseTimestamp", "type": "long"}*
* ]*
*}*
Please let me know if I am doing something wrong!
Thanking you in advance!
______________________
*Kind Regards,*
*Anshuman Ghosh*
*Contact - +49 179 9090964*
