Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5830#discussion_r180538022
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java
---
@@ -33,6 +33,8 @@
import org.apache.flink.streaming.api.TimeDomain;
import org.apache.flink.streaming.api.TimerService;
import
org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction;
+import
org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction.Context;
--- End diff --
Unused import.
---
