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.
... View more
