[ 
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)

Reply via email to