Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r169051991
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperatorTest.java
---
@@ -358,6 +365,8 @@ public void testFunctionWithBroadcastState() throws
Exception {
private final Map<String, Integer> expectedBroadcastState;
private final long timerTs;
+ static final String EXPECTED_KEY = "trigger";
--- End diff --
same here.
---
