Support Questions

Find answers, ask questions, and share your expertise

Apache Nifi: Cannot convert value <field> of type class org.apache.nifi.serialization.record.MapRecord to Long for <field>

avatar
New Contributor

Hello everyone! I'm new to Apache Nifi and I'm trying to get some data from a database (db1), perform a lookup using another another database (db2) and then loading this new data into a redshift. The problem is that my LookUp Process fails.

 

The incoming data from the db1 looks like the following:

 

{
transacition_id: 123
customer_id: 321
amount: U$10.0
} 

On the db2 I have this:

{
pk_customer: 001
src_sys_key: 321
customer_name: "example"
}

What I would like to do is get the pk_customer from the db2 by matching customer_id with src_sys_key.

The current Nifi flow:

1Dhpf.png

 

LookupRecord settings:

L6YBh.png

 

And finally the LookupService (Database Record Lookup):

spGLM.png

 

Getting the following error:

gJkTW.png

Can anyone help me, please?

Thank you in advance!

0 REPLIES 0