[ https://issues.apache.org/jira/browse/NIFI-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ilya Kovalev updated NIFI-8141: ------------------------------- Affects Version/s: 1.12.1 > errorHandlingOutputStream don't close inner output stream > --------------------------------------------------------- > > Key: NIFI-8141 > URL: https://issues.apache.org/jira/browse/NIFI-8141 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Affects Versions: 1.12.1 > Reporter: Ilya Kovalev > Priority: Minor > > Try to execute below groovy script > {code:java} > FlowFile ff = session.get() > OutputStream os = session.write(ff) > os.write("1".getBytes("UTF-8")) > os.flush() > os.close() > session.transfer(ff, REL_SUCCESS) > os.write("2".getBytes("UTF-8")) > os.flush() > os.close(){code} > in success queue you find 1 flowfile with 1 byte size but in content > repository you can find > file with content "12" > In this way NiFi write all content after stream was closed but not claim it. > write(ff) in MockProcessSession has the same problem. > -- This message was sent by Atlassian Jira (v8.3.4#803005)