[ 
https://issues.apache.org/jira/browse/FLINK-39949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18090055#comment-18090055
 ] 

Jubin Soni commented on FLINK-39949:
------------------------------------

So in practical terms: if you have a Flink job running on 
{{HashMapStateBackend}} and want to migrate it to {{{}ForSt{}}}, you take a 
savepoint and restore into ForSt. Without this PR, that throws 
{{{}UnsupportedOperationException{}}}. With it, the restore works.

It does not cover:
 * Restoring ForSt's own incremental checkpoints (that's 
{{{}ForStIncrementalRestoreOperation{}}}, which already exists)
 * ForSt → ForSt restore from its own savepoints (ForSt only produces 
{{NATIVE}} format savepoints, not {{{}CANONICAL{}}})

So the use case is cross-backend migration into ForSt.

> [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)

Reply via email to