[
https://issues.apache.org/jira/browse/FLINK-23396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381196#comment-17381196
]
Dawid Wysakowicz commented on FLINK-23396:
------------------------------------------
SQL does not support Flink version upgrades for now.
> Exception when restoring SQL job after upgrade from 1.12 to 1.13
> ----------------------------------------------------------------
>
> Key: FLINK-23396
> URL: https://issues.apache.org/jira/browse/FLINK-23396
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.13.1
> Reporter: Maciej Bryński
> Priority: Major
>
> Hi,
> I have following problem.
> I'm trying to upgrade my SQL job from 1.12 to 1.13 by restoring from
> savepoint.
> As the result I'm getting exception:
> {code:java}
> org.apache.flink.runtime.client.JobInitializationException: Could not start
> the JobMaster.
> at
> org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
> at
> java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown
> Source)
> at
> java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown
> Source)
> at
> java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
> at
> java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown
> Source)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
> at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
> at
> java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
> Source)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
> Source)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
> Source)
> at java.base/java.lang.Thread.run(Unknown Source)
> Caused by: java.util.concurrent.CompletionException:
> java.lang.IllegalStateException: Failed to rollback to checkpoint/savepoint
> hdfs://nsenv2/user/vvp/aggregation/job/savepoints/e9ff9947-c6ea-42f5-816d-ce8d541c0695/savepoint-d78bba-27fd4ad2a173.
> Cannot map checkpoint/savepoint state for operator
> 73e9cbce0842c813c6aba88179874091 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.
> at
> java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown
> Source)
> at
> java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown
> Source)
> ... 7 more
> Caused by: java.lang.IllegalStateException: Failed to rollback to
> checkpoint/savepoint
> hdfs://nsenv2/user/vvp/aggregation/job/savepoints/e9ff9947-c6ea-42f5-816d-ce8d541c0695/savepoint-d78bba-27fd4ad2a173.
> Cannot map checkpoint/savepoint state for operator
> 73e9cbce0842c813c6aba88179874091 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.
> at
> org.apache.flink.runtime.checkpoint.Checkpoints.throwNonRestoredStateException(Checkpoints.java:230)
> at
> org.apache.flink.runtime.checkpoint.Checkpoints.loadAndValidateCheckpoint(Checkpoints.java:194)
> at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.restoreSavepoint(CheckpointCoordinator.java:1629)
> at
> org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.tryRestoreExecutionGraphFromSavepoint(DefaultExecutionGraphFactory.java:163)
> at
> org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:138)
> at
> org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:342)
> at
> org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:190)
> at
> org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:120)
> at
> org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:132)
> at
> org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110)
> at
> org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:340)
> at
> org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:317)
> at
> org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:107)
> at
> org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:95)
> at
> org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
> ... 7 more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
