Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5500#discussion_r171252617 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java --- @@ -118,7 +118,7 @@ * @throws Exception This method may throw exceptions. Throwing an exception will cause the operation * to fail and may trigger recovery. */ - public void onTimer(final long timestamp, final OnTimerContext ctx, final Collector<OUT> out) throws Exception { + public void onTimer(final long timestamp, final OnTimerContext<KS> ctx, final Collector<OUT> out) throws Exception { --- End diff -- Remove the `<KS>`.
---