Support Questions
Find answers, ask questions, and share your expertise

Nifi Bulk Ingestion

Nifi Bulk Ingestion

New Contributor

Hi guys, I'm really new whit this technology. I'm trying to get multiple records from oracle Database then merge them in one file and put in other oracle table, but I'm stuck with this error "Put Database Record [id] due to none of the fields in the record map to the columns defined by the tablename1 table." 

Eilean_0-1616167266050.png

 

This is my structure

Eilean_1-1616167980751.png

This are the headers from Query Database Table's flow file output

 

 

 

Objavro.schemaş
{"type":"record","name":"tablename","namespace":"any.data",
"fields":[
{"name":"UPPERCOL0","type":["null",{"type":"bytes","logicalType":"decimal","precision":10,"scale":0}]},
{"name":"UPERCOL11","type":["null",{"type":"long","logicalType":"timestamp-millis"}]},
{"name":"UPPERCOL2","type":["null","string"]},
{"name":"UPPERCOL3","type":["null","string"]},
{"name":"UPPERCOL4","type":["null","string"]},
{"name":"UPPERCOL5","type":["null","string"]},
{"name":"UPPERCOL6","type":["null",{"type":"bytes","logicalType":"decimal","precision":3,"scale":0}]},
{"name":"UPPERCOL7","type":["null","string"]},
{"name":"UPPERCOL8","type":["null","string"]},
{"name":"UPPERCOL9","type":["null","string"]},
{"name":"UPPERCOL10","type":["null",{"type":"long","logicalType":"timestamp-millis"}]}
]}avro.

 

 

 

 

This are the headers from Merge Record's flow file output

 

 

 

 

Objavro.schemaş
{"type":"record","name":"tablename","namespace":"any.data",
"fields":[
{"name":"UPPERCOL0","type":["null",{"type":"bytes","logicalType":"decimal","precision":10,"scale":0}]},
{"name":"UPPERCOL1","type":["null",{"type":"long","logicalType":"timestamp-millis"}]},
{"name":"UPPERCOL2","type":["null","string"]},
{"name":"UPPERCOL3","type":["null","string"]},
{"name":"UPPERCOL4","type":["null","string"]},
{"name":"UPPERCOL5","type":["null","string"]},
{"name":"UPPERCOL6","type":["null",{"type":"bytes","logicalType":"decimal","precision":3,"scale":0}]},
{"name":"UPPERCOL7","type":["null","string"]},
{"name":"UPPERCOL8","type":["null","string"]},
{"name":"UPPERCOL9","type":["null","string"]},
{"name":"UPPERCOL10","type":["null",{"type":"long","logicalType":"timestamp-millis"}]}
]}avro.

 

 

 

This is my Avro schema

 

 

{"type":"record","name":"tablename","namespace":"any.data",
"fields":[
{"name":"UPPERCOL0","type":["null",{"type":"bytes","logicalType":"decimal","precision":10,"scale":0}]},
{"name":"UPPERCOL1","type":["null",{"type":"long","logicalType":"timestamp-millis"}]},
{"name":"UPPERCOL2","type":["null","string"]},
{"name":"UPPERCOL3","type":["null","string"]},
{"name":"UPPERCOL4","type":["null","string"]},
{"name":"UPPERCOL5","type":["null","string"]},
{"name":"UPPERCOL6","type":["null",{"type":"bytes","logicalType":"decimal","precision":3,"scale":0}]},
{"name":"UPPERCOL7","type":["null","string"]},
{"name":"UPPERCOL8","type":["null","string"]},
{"name":"UPPERCOL9","type":["null","string"]},
{"name":"UPPERCOL10","type":["null",{"type":"long","logicalType":"timestamp-millis"}]}
]}

 

 

 

 

Could you please help me with this problem?

1 REPLY 1

Re: Nifi Bulk Ingestion

Expert Contributor

As the error suggested, check the target table column definition