Myasuka commented on a change in pull request #18086:
URL: https://github.com/apache/flink/pull/18086#discussion_r771183731
##########
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java
##########
@@ -302,6 +302,14 @@ public EmbeddedRocksDBStateBackend
configure(ReadableConfig config, ClassLoader
// State backend methods
// ------------------------------------------------------------------------
+ @Override
+ public boolean supportsNoClaimRestoreMode() {
+ // We are able to create full snapshots when requested by
+ // CheckpointOptions#isForcedFullSnapshot. (we might potentially
reuplod some shared files
Review comment:
Same problem here.
##########
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
##########
@@ -281,6 +281,14 @@ public StateBackend getCheckpointBackend() {
return checkpointStreamBackend;
}
+ @Override
+ public boolean supportsNoClaimRestoreMode() {
+ // We are able to create full snapshots when requested by
+ // CheckpointOptions#isForcedFullSnapshot. (we might potentially
reupload some shared files
Review comment:
This method `CheckpointOptions#isForcedFullSnapshot` has been dropped in
current version of PR.
--
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]
