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