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)
