You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2021/06/21 16:56:00 UTC

[jira] [Commented] (NIFI-8719) ProcessSession may leave open references to files in content repo until committed/rolled back

    [ https://issues.apache.org/jira/browse/NIFI-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366730#comment-17366730 ] 

ASF subversion and git services commented on NIFI-8719:
-------------------------------------------------------

Commit b1ad13c83588d9206ceb8a157acb9bdb7fdbd4f8 in nifi's branch refs/heads/main from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=b1ad13c ]

NIFI-8719: Ensure that when OutputStream is returned from StandardProcessSession.write, upon close of the OutputStream we close the underlying resources.

Signed-off-by: Matthew Burgess <ma...@apache.org>

This closes #5170


> ProcessSession may leave open references to files in content repo until committed/rolled back
> ---------------------------------------------------------------------------------------------
>
>                 Key: NIFI-8719
>                 URL: https://issues.apache.org/jira/browse/NIFI-8719
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>            Reporter: Mark Payne
>            Assignee: Mark Payne
>            Priority: Critical
>             Fix For: 1.14.0
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> The {{ProcessSession}} class offers several API calls that make it possible to write to the contents of a FlowFile. One of those is:
> {code:java}
> OutputStream write(FlowFile source); {code}
> When this is called, the session returns an OutputStream that the caller is responsible for closing. However, when the OutputStream is closed, the underlying stream to the content repository is neither closed nor made available for reuse. As a result, if this is used to write to many FlowFiles, those FlowFiles can each be written to a separate file on disk as well as be left open until the session is committed or rolled back.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)