[
https://issues.apache.org/jira/browse/FLINK-39949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18090053#comment-18090053
]
Jubin Soni commented on FLINK-39949:
------------------------------------
My proposal is to implement full snapshot restore support for the ForSt state
backend. I've already put together a PR
[(#28472|https://github.com/apache/flink/pull/28472]) that does this — it adds
a {{ForStFullRestoreOperation}} class (mirroring
{{{}RocksDBFullRestoreOperation{}}}) and wires it into the builder.
Happy to hear your thoughts on whether this is the right direction given the
experimental status.
Alternatively, I can close this issue entirely and leave the existing exception
as-is. Happy to approach either way.
> [ForSt] State restore from savepoints/checkpoints not supported
> ---------------------------------------------------------------
>
> Key: FLINK-39949
> URL: https://issues.apache.org/jira/browse/FLINK-39949
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / State Backends
> Reporter: Jubin Soni
> Priority: Minor
> Labels: pull-request-available
>
> The ForSt state backend currently does not support restoring from savepoints
> or checkpoints. When a restore is attempted,
> {{ForStKeyedStateBackendBuilder#restoreForStKeyedStateBackend()}}
> unconditionally throws the following exception:
> UnsupportedOperationException: Not support restoring yet for ForStStateBackend
>
> *File location:*
> {{flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java}}
> Line: 428
> *Steps to Reproduce:*
> # Configure a Flink job to use the ForSt state backend
> # Take a checkpoint or savepoint
> # Restart the job and attempt to restore from that checkpoint/savepoint
> *Expected Result:*
> The job should resume from the checkpoint with all state intact.
> *Actual Result:*
> The job fails with:
> UnsupportedOperationException: Not support restoring yet for ForStStateBackend
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
