Member since
11-12-2019
3
Posts
0
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
8235 | 12-04-2019 05:45 AM |
12-04-2019
05:45 AM
The solution was changing the datatype definition in the schema from logicaltype to logicalType (Upper case T there for you). wtf!!! Eg: *{ "name" : "time_stamp", "type" : ["null", { "type":"long", "logicalType":"timestamp-millis"}* The irritating part is that the schema validates. No warning! But, if you mistakenly use String instead of the correct string (lower case S) or Type instead of type in you schema, your schema will not validate and you can correct it. But for logicalType no.
... View more
11-15-2019
02:42 AM
Thank you for your reply! The timestamp format is an option in the CSVReader Controller Service, which is a valid service record reader in the PutDatabaseRecord processor. The format used, is working fine in other workflows with the same setup.
... View more
11-12-2019
10:03 AM
Getting error when inserting a csv-file into a MSSQL database using the PutDatabaseRecord (1.9.2) processor in Nifi. ListFile → FetchFile → PutDatabaseRecord
The schema used:
{ "type" : "record", "name" : "mibas_t005_talkgroup", "fields" : [
{ "name" : "talkgroup_ref", "type" : ["null","long"] },
{ "name" : "fleet_ref", "type" : ["null","long"] },
{ "name" : "talkgroup_id", "type" : ["null","long"] },
{ "name" : "talkgroup_name", "type" : ["null","string"] },
{ "name" : "group_type", "type" : ["null","string"] },
{ "name" : "dispatcher_ref", "type" : ["null","string"] },
{ "name" : "multigroup_ref", "type" : ["null","string"] },
{ "name" : "owner_", "type" : ["null","string"] },
{ "name" : "fne_state", "type" : ["null","string"] },
{ "name" : "addl_attrvar", "type" : ["null","string"] },
{ "name" : "last_user_modified", "type" : ["null","string"] },
{ "name" : "time_stamp", "type" : ["null", { "type":"long", "logicaltype":"timestamp-millis"} ]},
{ "name" : "fne_oid", "type" : ["null","string"] }]}
Datatype in the table is DateTime
... View more
Labels:
- Labels:
-
Apache NiFi