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