You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/08/22 16:22:20 UTC

[flink] branch release-1.9 updated: [FLINK-13761][scala] Deprecate Scala SplitStream

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 36366ac  [FLINK-13761][scala] Deprecate Scala SplitStream
36366ac is described below

commit 36366ac477342c289fc54c6b613ad40189be9168
Author: 张志豪 <iz...@hotmail.com>
AuthorDate: Sun Aug 18 21:16:20 2019 +0800

    [FLINK-13761][scala] Deprecate Scala SplitStream
    
    Deprecate Scala SplitStream which has been superseded by side outputs.
    
    This closes #9474.
---
 .../main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
index ca4bcc0..16a5a48 100644
--- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
+++ b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
@@ -28,6 +28,7 @@ import org.apache.flink.streaming.api.datastream.{ SplitStream => SplitJavaStrea
  * To apply a transformation on the whole output simply call
  * the appropriate method on this stream.
  */
+@deprecated("Please use side outputs instead of split/select", "deprecated since 1.8.2")
 @Public
 class SplitStream[T](javaStream: SplitJavaStream[T]) extends DataStream[T](javaStream){