Github user makeyang commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r187294295 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java --- @@ -39,11 +40,18 @@ private final long timestamp; private final K key; private final N namespace; + private final String hashKey; --- End diff -- same as above
---