flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode
Date Fri, 11 Sep 2015 09:21:45 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14740463#comment-14740463

ASF GitHub Bot commented on FLINK-2622:

Github user HuangWHWHW commented on a diff in the pull request:

    --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/test/java/org/apache/flink/streaming/scala/api/CsvOutputFormatITCase.java
    @@ -36,6 +37,10 @@ protected void preSubmit() throws Exception {
     	protected void testProgram() throws Exception {
     		OutputFormatTestPrograms.wordCountToCsv(WordCountData.TEXT, resultPath);
    +		OutputFormatTestPrograms.wordCountToCsv(WordCountData.TEXT, resultPath, 1);
    --- End diff --
    If it is expected to fail, could you tell me how to pass the test?
    Just I have no idea about this.

> Scala DataStream API does not have writeAsText method which supports WriteMode
> ------------------------------------------------------------------------------
>                 Key: FLINK-2622
>                 URL: https://issues.apache.org/jira/browse/FLINK-2622
>             Project: Flink
>          Issue Type: Bug
>          Components: Scala API, Streaming
>            Reporter: Till Rohrmann
> The Scala DataStream API, unlike the Java DataStream API, does not support a {{writeAsText}}
method which takes the {{WriteMode}} as a parameter. In order to make the two APIs consistent,
it should be added to the Scala DataStream API.

This message was sent by Atlassian JIRA

View raw message