Dariusz Seweryn created NIFI-14696:
--------------------------------------
Summary: KinesisRecordProcessorRecord does not handle
IllegalTypeConversionException
Key: NIFI-14696
URL: https://issues.apache.org/jira/browse/NIFI-14696
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Affects Versions: 2.4.0
Reporter: Dariusz Seweryn
Assignee: Dariusz Seweryn
{{KinesisRecordProcessorRecord#processRecord}} method may encounter an
{{IllegalTypeConversionException}} while trying write the record. In this case
the exception is caught in the
{{AbstractKinesisRecordProcessor#attemptProcessRecord}} function.
There are two problems here as {{KinesisRecordProcessorRecord#processRecord}}
is responsible for:
# routing problematic records to the Failure Relationship
# closing the the FlowFile at the last record
Routing to Failure can be fixed by adding {{IllegalTypeConversionException}}
handling to the catch block.
Closing the success FlowFile should happen if it is not empty even if the last
record processed is invalid — currently this is not the case.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
