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

[Shang Yuanchun (Jira)]

Rannn Tao created FLINK-9941:
--------------------------------

             Summary: 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


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}
 



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