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

    https://github.com/apache/flink/pull/5500#discussion_r171252385
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
 ---
    @@ -163,12 +163,16 @@ public void onTimer(final long timestamp, final 
OnTimerContext ctx, final Collec
        /**
         * Information available in an invocation of {@link #onTimer(long, 
OnTimerContext, Collector)}.
         */
    -   public abstract class OnTimerContext extends KeyedReadOnlyContext {
    +   public abstract class OnTimerContext<KS> extends KeyedReadOnlyContext {
    --- End diff --
    
    You can remove the `<KS>` as done in 
https://github.com/apache/flink/pull/5481 


---

Reply via email to