Myasuka commented on a change in pull request #11491:
[FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata
URL: https://github.com/apache/flink/pull/11491#discussion_r397587352
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
##########
@@ -640,4 +639,17 @@ private static void checkStateMappingCompleteness(
return subtaskKeyedStateHandles;
}
+
+ private static <T extends AbstractChannelStateHandle<?>>
OperatorStateRepartitioner<T> nonRescalingPartitioner(String logStateName) {
Review comment:
I think there is no UT or IT to cover this method currently in this PR (e.g.
throw expected exception).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
