Thanks for your response. I tried this method,but i can not work out the
expected result. i use PutMongoRecord and set record reader is
JsonTreeReader, and my schema is
{
"namespace": "nifi",
"name": "userRecord",
"type": "record",
"fields": [
{ "name": "time", "type" : {
"type" : "long",
"logicalType" :
"timestamp-millis"
}
},
{ "name": "count", "type": ["null","long"] }
]
}
The error is: successfully parsed a json object from input but failed to
convert into a record object with the given schema.
what's wrong with this? thanks you in advance.
--
Sent from: http://apache-nifi-developer-list.39713.n7.nabble.com/