Mark Payne created NIFI-8680:
--------------------------------
Summary: Process Session does not throw Exception when calling
commitAsync() without properly handling all FlowFiles
Key: NIFI-8680
URL: https://issues.apache.org/jira/browse/NIFI-8680
Project: Apache NiFi
Issue Type: Bug
Components: Core Framework
Reporter: Mark Payne
Assignee: Mark Payne
Fix For: 1.14.0
When the commitAsync methods were added to ProcessSession, the javadocs
indicate:
{code:java}
* @throws IllegalStateException if called from within a callback (See {@link
#write(FlowFile, StreamCallback)}, {@link #write(FlowFile,
OutputStreamCallback)},
* {@link #read(FlowFile, InputStreamCallback)}).
*
* @throws FlowFileHandlingException if any FlowFile is not appropriately
accounted for by transferring it to a Relationship (see {@link
#transfer(FlowFile, Relationship)})
* or removed (see {@link #remove(FlowFile)}. {code}
However, those Exceptions don't actually get thrown. In those situations, the
session is rolled back, the error logged, but the session does not re-throw the
Exception
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
