Hi All,
I want to insert csv data (which is getting generated from executsql) to database table.
csv header are same as that of columns in table:
TIME timestamp,
CAUSE varchar(200) NOT NULL,
CATEGORY varchar(100),
PREVIOUSCOUNT numeric(11,0),
CURRENTCOUNT numeric(11,0),
AVERAGE numeric(11,3),
SEVERITY varchar(30)
My current flow is like :
Executesql > updateattribute > validatecsv > updateattribute > putdatabase
I am using avroschemaregistry and putting data as:
{
"type":"record",
"name":"TestRecord",
"fields":[
{
"name":"TIME",
"type":{"type":"long","logicalType":"timestamp-millis"}
},
{
"name":"CAUSE",
"type":"string"
},
{
"name":"CATEGORY",
"type":"string"
},
{
"name":"PREVIOUSCOUNT",
"type":"float"
},
{
"name":"CURRENTCOUNT",
"type":"float"
},
,
{
"name":"AVERAGE",
"type":"float"
},
,
{
"name":"SEVERITY",
"type":"string"
}
]
}


Please help as i am stuck , i tried everything making translate field name to true and false both, but getting the same error.
Looking for quick response.