[FLINK-3610] Scala DataStream#addSink returns Java DataStreamSink

• Type: Sub-task
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.0.0
• Fix Version/s: 2.0.0
• Component/s: API / DataStream, API / Scala
• Labels: auto-unassigned
• Assignee: Unassigned
• Reporter: Márton Balassi
• Created: 13/Mar/16 04:26
• Updated: 27/Apr/21 23:25

Description

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.

[1] https://github.com/apache/flink/blob/master/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala#L928-L929