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

ASF GitHub Bot commented on FLINK-2465:
---------------------------------------

GitHub user ffbin opened a pull request:

    https://github.com/apache/flink/pull/972

    [FLINK-2465] Fix SocketClientSink closeConnection function memory leak

    When closeConnection, should call dataOutputStream.close() instead of 
dataOutputStream.flush()  because close() will call flush() first and then 
releases any system resources associated with this stream. Only call 
dataOutputStream.flush() cause memory leak.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/ffbin/flink FLINK_2465

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/972.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #972
    
----
commit a5222a5af269931ce0c641886002fda42e916733
Author: ffbin <[email protected]>
Date:   2015-08-03T07:50:26Z

    Fix [FLINK-2465] SocketClientSink closeConnection function has memory leak

----


> SocketClientSink closeConnection function has memory leak
> ---------------------------------------------------------
>
>                 Key: FLINK-2465
>                 URL: https://issues.apache.org/jira/browse/FLINK-2465
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>    Affects Versions: 0.8.1
>            Reporter: fangfengbin
>            Priority: Minor
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to