Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5500#discussion_r168697719 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java --- @@ -324,6 +324,11 @@ public TimeDomain timeDomain() { return timeDomain; } + @Override + public KS getCurrentKey() { --- End diff -- It needs at least some most basic test coverage
---