dawidwys commented on a change in pull request #18086:
URL: https://github.com/apache/flink/pull/18086#discussion_r769355897
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
##########
@@ -1650,6 +1657,10 @@ public boolean restoreSavepoint(
case LEGACY:
checkpointProperties =
CheckpointProperties.forSavepoint(false);
break;
+ case NO_CLAIM:
+ this.forceFullSnapshot = true;
Review comment:
I expected this question :) First of all, I wanted to get your opinion
on the solution first. I could not come up with an easy way to test it, but I
do want to spent some more time on a test.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
