fredia commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1262496038
##########
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageWorkerView.java:
##########
@@ -75,4 +77,14 @@ CheckpointStreamFactory resolveCheckpointStorageLocation(
* @return A toolset for additional operations for state owned by tasks.
*/
CheckpointStateToolset createTaskOwnedCheckpointStateToolset();
+
+ /**
+ * Return {@link
org.apache.flink.runtime.state.filesystem.FsMergingCheckpointStorageAccess} if
+ * file merging is enabled. Otherwise, return itself.
+ */
+ default CheckpointStorageWorkerView toFileMergingStorage(
Review Comment:
Thanks for your suggestion, putting `toFileMergingStorage` into
`CheckpointStorageWorkerView` is to reduce the [type checking in
StreamTask](https://github.com/apache/flink/pull/22890#discussion_r1251648094).
--
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]
