Member since
02-14-2024
6
Posts
3
Kudos Received
0
Solutions
03-06-2024
12:10 AM
I'm using a LookupRecord Processor to look up a MySQL table. The incoming Flow File Records is in Avro format have a column 'ID_BB_UNIQUE', which should be mapped to the field named 'ID_BB_Unique' in the MySQL table for lookup. After lookup, I return 'ID_BB_Unique' as 'Lookup_ID_BB_Unique' and insert this field value to the Flow File Records. However, the processor throwed me a java.lang.NullPointerException: null value for (non-nullable) string at nifiRecord.Lookup_ID_BB_Unique, while 'ID_BB_UNIQUE' in Flow File is confirmed to not have nulls, and 'ID_BB_Unique' is set to be not null in database. What might be causing this exception and how can I solve it? (If I choose 'Insert Entire Record' as Record Result Contents property in the processor, there is no such exception, but I believe it is not the correct logic to do my lookups and does not solve the problem from root.) LookupRecord Configuration: LookupService Configuration: Error:
... View more
Labels:
- Labels:
-
Apache NiFi
03-05-2024
11:43 PM
Hi @SAMSAL , I have thought to write a stored procedure to compare field values and then log value changes to solve problem 2, but one thing is that Records in a Flow File cannot be passed to a stored procedure and interact with the database data in a stored procedure directly. Maybe I didn't know the correct processor or script to use. Do you have any insight on this?
... View more
02-21-2024
01:45 PM
I had a need for multiple Lookups...custom Groovy processor with several LookUp services as a part of it...consolidated that, routed accordingly, and performed faster.
... View more