Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185470576
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -622,20 +622,23 @@ public HeapSnapshotStrategy(
final Map<String, Integer> kVStateToId = new
HashMap<>(stateTables.size());
- final Map<StateTable<K, ?, ?>, StateTableSnapshot>
cowStateStableSnapshots =
+ final Map<String, StateTableSnapshot>
cowStateStableSnapshots =
new HashedMap(stateTables.size());
--- End diff --
Seems like I accidentally used `new HashedMap(...)` here instead of Java's
`new HashMap<>(...)`. As you touch this spot already, maybe you can just also
correct that?
---
