flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: [streaming, scala] Scala DataStream#addSink returns Java DataStreamSink
Date Sun, 13 Mar 2016 04:27:55 GMT
The JIRA issue is FLINK-3610.

On Sat, Mar 12, 2016 at 8:39 PM, Márton Balassi <balassi.marton@gmail.com>
wrote:

>
> I have just come across a shortcoming of the streaming Scala API: it
> completely lacks the Scala implementation of the DataStreamSink and
> instead the Java version is used. [1]
>
> I would regard this as a bug that needs a fix for 1.0.1. Unfortunately
> this is also api-breaking.
>
> Will post it to JIRA shortly - but issues.apache.org is unresponsive for
> me currently. Wanted to raise the issue here as it might affect the api.
>
> [1] https://github.com/apache/flink/blob/master/flink-streaming-scala
> /src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
> #L928-L929
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message