Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5908#discussion_r185729732
--- 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 --
Why do we need this string key and not just use the normal hash code? If
the answer is because you want to use it in `ConcurrentHashMap`, there are
other ways to accomplish this.
---
