cshuo commented on issue #17658: URL: https://github.com/apache/hudi/issues/17658#issuecomment-3684788849
> In the 3rd step, I should use the configuration key `execution.savepoint.path` instead of `execution.state-recovery.path`(Available in Flink 1.20, I am using Flink 1.17 ) (https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/sqlclient/#start-a-sql-job-from-a-savepoint) > > But, when I run the `insert select sql` again and try to restore from savepoint, the error is same with when I try to restore from checkpoint.... > > ``` > [ERROR] Could not execute SQL statement. Reason: > java.lang.IllegalStateException: Failed to rollback to checkpoint/savepoint hdfs://hadoop.master:9000/flink/checkpoints/test_flink_incremental_second_20251221_03/d7cc6b5d643f3a8976df93f6e9aa0c48/chk-9. > Cannot map checkpoint/savepoint state for operator c43c1940ad62bf3bc996ebfabca09279 to the new program, because the operator is not available in the new program. If you want to allow to skip this, you can set the --allowNonRestoredState option on the CLI. > ``` > > > Thanks [@cshuo](https://github.com/cshuo) for the reply. > > I am back with no luck. > > > > 0. In the Flink SQL client, run the insert select as before > > 1. set 'state.savepoints.dir'='hdfs:///flink/savepoints/table001' --- save the savepoint data > > 2. STOP JOB '228d70913eab60dda85c5e7f78b5782c' WITH SAVEPOINT; -- 228d70913eab60dda85c5e7f78b5782c is the job id that runs continous insert select > > > > ----Before restart the insert select query,set the recovery path 3. SET 'execution.state-recovery.path' = 'hdfs:///flink/savepoints/table001/savepoint-f78b5782c'; > > > > 4. Kick off the insert .. select .. sqlThe sql `successfully` submitted and run. But, instead of consuming from the saved commits, it just consume all the data in the select table. Looks savepoint doesn't take effect at all. Seems the path in the exception message is still not the savepoint path you configured, plz make sure you've set the savepoint path properly. -- 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]
