You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Nicolas Fraison (Jira)" <ji...@apache.org> on 2023/04/14 13:27:00 UTC
[jira] [Created] (FLINK-31812) SavePoint from /jars/:jarid:/run api on body is not anymore emptyToNull if empty
Nicolas Fraison created FLINK-31812:
---------------------------------------
Summary: SavePoint from /jars/:jarid:/run api on body is not anymore emptyToNull if empty
Key: FLINK-31812
URL: https://issues.apache.org/jira/browse/FLINK-31812
Project: Flink
Issue Type: Bug
Affects Versions: 1.17.0
Reporter: Nicolas Fraison
Since https://issues.apache.org/jira/browse/FLINK-29543 the
savepointPath from the body is not anymore transform to null if empty: https://github.com/apache/flink/pull/21012/files#diff-c6d9a43d970eb07642a87e4bf9ec6a9dc7d363b1b5b557ed76f73d8de1cc5a54R145
This leads to issue running a flink job in release 1.17 with lyft operator which set savePoint in body to "": [https://github.com/lyft/flinkk8soperator/blob/master/pkg/controller/flinkapplication/flink_state_machine.go#L721]
Issue faced by the job as the savepointPath is set to "":
{code:java}
org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
3 at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
4 at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
5 at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
6 at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
7 at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705)
8 at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
9 at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
10 at java.base/java.lang.Thread.run(Thread.java:829)
11Caused by: java.util.concurrent.CompletionException: java.lang.IllegalArgumentException: empty checkpoint pointer
12 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
13 at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319)
14 at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702)
15 ... 3 more
16Caused by: java.lang.IllegalArgumentException: empty checkpoint pointer
17 at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
18 at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorageAccess.resolveCheckpointPointer(AbstractFsCheckpointStorageAccess.java:240)
19 at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorageAccess.resolveCheckpoint(AbstractFsCheckpointStorageAccess.java:136)
20 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.restoreSavepoint(CheckpointCoordinator.java:1824)
21 at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.tryRestoreExecutionGraphFromSavepoint(DefaultExecutionGraphFactory.java:223)
22 at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:198)
23 at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:365)
24 at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:210)
25 at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:136)
26 at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:152)
27 at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:119)
28 at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:371)
29 at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:348)
30 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:123)
31 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:95)
32 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
33 at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700)
34 ... 3 more
35 {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)