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