[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

[pnowojski]

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

    https://github.com/apache/flink/pull/5481#discussion_r169571457
  
    --- Diff: 
flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala
 ---
    @@ -473,6 +496,28 @@ class DataStreamTest extends AbstractTestBase {
         
assert(getOperatorForDataStream(flatMapped).isInstanceOf[ProcessOperator[_, _]])
       }
     
    +  /**
    +    * Verify that a [[DataStream.process(KeyedProcessFunction)]] call is 
correctly
    --- End diff --
    
    ditto


---