[FLINK-9941] Flush in ScalaCsvOutputFormat before close method

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.1, 1.6.4, 1.7.2, 1.8.1
• Fix Version/s: 1.9.1, 1.10.0
• Component/s: API / Scala
• Labels: pull-request-available
• Assignee: Jiayi Liao
• Reporter: Ran Tao
• Created: 25/Jul/18 05:51
• Updated: 19/Sep/19 12:11
• Resolved: 19/Sep/19 12:11

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. 

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

 

Issue Links

• links to: GitHub Pull Request #9467