GitHub user fi-ecavc added a comment to the discussion: When the job is
executed, the job automatically exits
2023-09-27 18:56:03.141 [flink-akka.actor.default-dispatcher-14] WARN
org.apache.streampark.flink.core.FlinkTableInitializer - [StreamPark]
Usage:can't fond config,you can set "--conf $path " in main arguments
2023-09-27 18:56:03.422 [flink-akka.actor.default-dispatcher-14] WARN
org.apache.streampark.flink.core.FlinkTableInitializer - [StreamPark]
useBlinkPlanner deprecated
2023-09-27 18:56:03.423 [flink-akka.actor.default-dispatcher-14] INFO
org.apache.streampark.flink.core.FlinkTableInitializer - [StreamPark]
components should work in streaming mode
2023-09-27 18:56:03,441 INFO
org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend [] - Using
predefined options: DEFAULT.
2023-09-27 18:56:03,515 WARN
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
[] - Application failed unexpectedly:
java.util.concurrent.CompletionException:
org.apache.flink.client.deployment.application.ApplicationExecutionException:
Could not execute application.
at java.util.concurrent.CompletableFuture.encodeThrowable(Unknown
Source) ~[?:?]
at java.util.concurrent.CompletableFuture.completeThrowable(Unknown
Source) ~[?:?]
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(Unknown
Source) ~[?:?]
at java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
~[?:?]
at java.util.concurrent.CompletableFuture.completeExceptionally(Unknown
Source) ~[?:?]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:337)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$2(ApplicationDispatcherBootstrap.java:254)
~[flink-clients-1.17.1.jar:1.17.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
~[?:?]
at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?]
at
org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:171)
~[flink-rpc-akka_b867cc67-f314-48e8-98a1-03cc514a20fc.jar:1.17.1]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_b867cc67-f314-48e8-98a1-03cc514a20fc.jar:1.17.1]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$withContextClassLoader$0(ClassLoadingUtils.java:41)
~[flink-rpc-akka_b867cc67-f314-48e8-98a1-03cc514a20fc.jar:1.17.1]
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
[flink-rpc-akka_b867cc67-f314-48e8-98a1-03cc514a20fc.jar:1.17.1]
at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
[flink-rpc-akka_b867cc67-f314-48e8-98a1-03cc514a20fc.jar:1.17.1]
at java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown
Source) [?:?]
at java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?]
Caused by:
org.apache.flink.client.deployment.application.ApplicationExecutionException:
Could not execute application.
... 14 more
Caused by: org.apache.flink.client.program.ProgramInvocationException: The main
method caused an error: Could not parse value '[DELETE_ON_CANCELLATION,
RETAIN_ON_CANCELLATION]' for key
'execution.checkpointing.externalized-checkpoint-retention'.
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
~[flink-clients-1.17.1.jar:1.17.1]
... 13 more
Caused by: java.lang.IllegalArgumentException: Could not parse value
'[DELETE_ON_CANCELLATION, RETAIN_ON_CANCELLATION]' for key
'execution.checkpointing.externalized-checkpoint-retention'.
at
org.apache.flink.configuration.Configuration.getOptional(Configuration.java:735)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.CheckpointConfig.configure(CheckpointConfig.java:856)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.configure(StreamExecutionEnvironment.java:1056)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.<init>(StreamExecutionEnvironment.java:294)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.StreamContextEnvironment.<init>(StreamContextEnvironment.java:107)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.StreamContextEnvironment.lambda$setAsContext$4(StreamContextEnvironment.java:223)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.lambda$getExecutionEnvironment$18(StreamExecutionEnvironment.java:2399)
~[flink-dist-1.17.1.jar:1.17.1]
at java.util.Optional.map(Unknown Source) ~[?:?]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionEnvironment(StreamExecutionEnvironment.java:2399)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.streampark.flink.core.FlinkStreamingInitializer.initEnvironment(FlinkStreamingInitializer.scala:163)
~[?:?]
at
org.apache.streampark.flink.core.FlinkTableInitializer.initEnvironment(FlinkTableInitializer.scala:269)
~[?:?]
at
org.apache.streampark.flink.core.FlinkTableInitializer$.initialize(FlinkTableInitializer.scala:82)
~[?:?]
at
org.apache.streampark.flink.core.scala.FlinkStreamTable.init(FlinkStreamTable.scala:56)
~[?:?]
at
org.apache.streampark.flink.core.scala.FlinkStreamTable.main(FlinkStreamTable.scala:46)
~[?:?]
at
org.apache.streampark.flink.core.scala.FlinkStreamTable.main$(FlinkStreamTable.scala:45)
~[?:?]
at
org.apache.streampark.flink.cli.SqlClient$StreamSqlApp$.main(SqlClient.scala:68)
~[?:?]
at
org.apache.streampark.flink.cli.SqlClient$.delayedEndpoint$org$apache$streampark$flink$cli$SqlClient$1(SqlClient.scala:58)
~[?:?]
at
org.apache.streampark.flink.cli.SqlClient$delayedInit$body.apply(SqlClient.scala:31)
~[?:?]
at scala.Function0.apply$mcV$sp(Function0.scala:34)
~[flink-scala_2.12-1.17.1.jar:1.17.1]
at scala.Function0.apply$mcV$sp$(Function0.scala:34)
~[flink-scala_2.12-1.17.1.jar:1.17.1]
at
scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
~[flink-scala_2.12-1.17.1.jar:1.17.1]
at scala.App.$anonfun$main$1$adapted(App.scala:76)
~[flink-scala_2.12-1.17.1.jar:1.17.1]
at scala.collection.immutable.List.foreach(List.scala:388)
~[flink-scala_2.12-1.17.1.jar:1.17.1]
at scala.App.main(App.scala:76) ~[flink-scala_2.12-1.17.1.jar:1.17.1]
at scala.App.main$(App.scala:74) ~[flink-scala_2.12-1.17.1.jar:1.17.1]
at org.apache.streampark.flink.cli.SqlClient$.main(SqlClient.scala:31)
~[?:?]
at org.apache.streampark.flink.cli.SqlClient.main(SqlClient.scala)
~[?:?]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:?]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown
Source) ~[?:?]
at java.lang.reflect.Method.invoke(Unknown Source) ~[?:?]
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
~[flink-clients-1.17.1.jar:1.17.1]
... 13 more
Caused by: java.lang.IllegalArgumentException: Could not parse value for enum
class
org.apache.flink.streaming.api.environment.CheckpointConfig$ExternalizedCheckpointCleanup.
Expected one of: [[DELETE_ON_CANCELLATION, RETAIN_ON_CANCELLATION,
NO_EXTERNALIZED_CHECKPOINTS]]
at
org.apache.flink.configuration.ConfigurationUtils.lambda$convertToEnum$10(ConfigurationUtils.java:389)
~[flink-dist-1.17.1.jar:1.17.1]
at java.util.Optional.orElseThrow(Unknown Source) ~[?:?]
at
org.apache.flink.configuration.ConfigurationUtils.convertToEnum(ConfigurationUtils.java:386)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.configuration.ConfigurationUtils.convertValue(ConfigurationUtils.java:329)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.configuration.Configuration.lambda$getOptional$3(Configuration.java:729)
~[flink-dist-1.17.1.jar:1.17.1]
at java.util.Optional.map(Unknown Source) ~[?:?]
at
org.apache.flink.configuration.Configuration.getOptional(Configuration.java:729)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.CheckpointConfig.configure(CheckpointConfig.java:856)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.configure(StreamExecutionEnvironment.java:1056)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.<init>(StreamExecutionEnvironment.java:294)
~[flink-dist-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.StreamContextEnvironment.<init>(StreamContextEnvironment.java:107)
~[flink-clients-1.17.1.jar:1.17.1]
at
org.apache.flink.client.program.StreamContextEnvironment.lambda$setAsContext$4(StreamContextEnvironment.java:223)
~[flink-clients-1.17.1.jar:1.17.1]
GitHub link:
https://github.com/apache/incubator-streampark/discussions/3205#discussioncomment-7123096
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
