Myasuka commented on a change in pull request #18840:
URL: https://github.com/apache/flink/pull/18840#discussion_r815545910
##########
File path:
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/SnapshotUtils.java
##########
@@ -52,12 +53,13 @@ private SnapshotUtils() {}
boolean isExactlyOnceMode,
boolean isUnalignedCheckpoint,
Configuration configuration,
- Path savepointPath)
+ Path savepointPath,
+ SnapshotType snapshotType)
Review comment:
After re-think current stats in Flink, I currently prefer we could only
support native and canonical savepoint. You can try to use native savepoint to
see whether it could meet your previous requestls. The native savepoint is much
close to full checkpoint and it could also support relocating the checkpoint
data to other place without modifying the metadata.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
