Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5500#discussion_r171252831 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java --- @@ -288,7 +288,7 @@ public long currentWatermark() { } } - private class OnTimerContextImpl extends KeyedBroadcastProcessFunction<KS, IN1, IN2, OUT>.OnTimerContext { + private class OnTimerContextImpl<KS> extends KeyedBroadcastProcessFunction<KS, IN1, IN2, OUT>.OnTimerContext<KS> { --- End diff -- Remove the `<KS>` in both places.
---