[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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

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.


public void close() throws IOException {
if (wrt != null) {

This message was sent by Atlassian JIRA