[
https://issues.apache.org/jira/browse/NIFI-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ilya Kovalev updated NIFI-8141:
-------------------------------
Description:
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.
was:
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.
> 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
> 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)
