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

[kl0u]

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

    https://github.com/apache/flink/pull/5481#discussion_r171235653
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
 ---
    @@ -132,15 +139,15 @@ public TimerService timerService() {
                }
        }
     
    -   private class OnTimerContextImpl extends ProcessFunction<IN, 
OUT>.OnTimerContext{
    +   private class OnTimerContextImpl extends KeyedProcessFunction<K, IN, 
OUT>.OnTimerContext<K> {
     
    --- End diff --
    
    With the proposed changes you can also remove the `<K>` in the 
`.OnTimerContext<K>`.


---