I'm receiving error "INT96 not yet implemented" while trying to fetch parquet file by NiFi using FetchParquet processor
Parquet file contains 1 column with timestamp. Here is Avro schema:
{
"namespace": "sna_project",
"name": "geo_subscriber",
"type":
"record",
"fields":
[
{ "name": "ecgi", "type":
"string" },
{ "name": "cell_dir", "type":
"int" },
{ "name": "service_processed_at",
"type": "timestamp" },
{ "name": "year", "type":
"int" },
{ "name": "month", "type":
"int" },
{ "name": "day", "type":
"int" }
]}
I tried to exchange timestamp datatype with other options, like:
- { "name": "service_processed_at", "type": "string" }
- { "name": "service_processed_at", "type": { "type" : "long",
"logicalType" : "timestamp-millis"} }
etc.
How can I read such parquet file using Nifi?