[jira] [Updated] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

["Rannn Tao (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rannn Tao updated FLINK-9941:
-----------------------------
    Description: 
Because not every stream's close method will flush, in order to ensure the stability of continuous integration, we need to manually call flush() before close().

I noticed that CsvOutputFormat (Java API) has done this. As follows.

 

 
{code:java}
//CsvOutputFormat
public void close() throws IOException {
if (wrt != null) {
this.wrt.flush();
this.wrt.close();
}
super.close();
}
{code}
 

  was:
Because not every stream's close method will be refreshed, in order to ensure the stability of continuous integration, we need to manually call flush() before close().

I noticed that CsvOutputFormat (Java API) has done this. As follows.

 

 
{code:java}
//CsvOutputFormat
public void close() throws IOException {
if (wrt != null) {
this.wrt.flush();
this.wrt.close();
}
super.close();
}
{code}
 


> Flush in ScalaCsvOutputFormat before close method
> -------------------------------------------------
>
>                 Key: FLINK-9941
>                 URL: https://issues.apache.org/jira/browse/FLINK-9941
>             Project: Flink
>          Issue Type: Improvement
>          Components: Scala API
>    Affects Versions: 1.5.1
>            Reporter: Rannn Tao
>            Priority: Major
>
> Because not every stream's close method will flush, in order to ensure the stability of continuous integration, we need to manually call flush() before close().
> I noticed that CsvOutputFormat (Java API) has done this. As follows.
>  
>  
> {code:java}
> //CsvOutputFormat
> public void close() throws IOException {
> if (wrt != null) {
> this.wrt.flush();
> this.wrt.close();
> }
> super.close();
> }
> {code}
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)