Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553958
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueStateSnapshot.java
---
@@ -60,36 +61,35 @@
/** Result of partitioning the snapshot by key-group. */
@Nullable
- private KeyGroupPartitionedSnapshot partitionedSnapshot;
+ private StateKeyGroupWriter partitionedSnapshot;
--- End diff --
nit: rename field---
