[jira] [Created] (NIFI-8680) Process Session does not throw Exception when calling commitAsync() without properly handling all FlowFiles

["Mark Payne (Jira)" <ji...@apache.org>]

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)