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>`.
---
