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

ASF GitHub Bot commented on FLINK-8456:
---------------------------------------

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

    https://github.com/apache/flink/pull/5425#discussion_r166973333
  
    --- Diff: 
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
 ---
    @@ -441,6 +463,26 @@ class DataStream[T](stream: JavaStream[T]) {
        */
       def broadcast: DataStream[T] = asScalaStream(stream.broadcast())
     
    +  /**
    +    * Sets the partitioning of the [[DataStream]] so that the output 
elements
    +    * are broadcasted to every parallel instance of the next operation. In 
addition,
    +    * it implicitly creates a
    --- End diff --
    
    I think the "creates a" is outdated here because you can specify multiple 
descriptors. This should also be fixed in the Java API.


> Add Scala API for Connected Streams with Broadcast State.
> ---------------------------------------------------------
>
>                 Key: FLINK-8456
>                 URL: https://issues.apache.org/jira/browse/FLINK-8456
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Streaming
>    Affects Versions: 1.5.0
>            Reporter: Kostas Kloudas
>            Assignee: Kostas Kloudas
>            Priority: Major
>             Fix For: 1.5.0
>
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to