Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5230#discussion_r159215876 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java --- @@ -613,7 +613,6 @@ private static void checkStateMappingCompleteness( Map<String, OperatorStateHandle.StateMetaInfo> partitionOffsets = operatorStateHandle.getStateNameToPartitionOffsets(); - --- End diff -- Both changes should go in a separate cleanup/refactoring commit.
---