lfw529 opened a new issue, #6622:
URL: https://github.com/apache/seatunnel/issues/6622

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   程序提交到yarn时,并未执行,而是直接失败
   
![2](https://github.com/apache/seatunnel/assets/82995456/cdbd618f-cf23-4e66-a06f-f23aa59dbe8a)
   
   
   
   ### SeaTunnel Version
   
   2.3.4
   
   ### SeaTunnel Config
   
   ```conf
   # Home directory of spark distribution.
   SPARK_HOME=${SPARK_HOME:-/opt/spark}
   # Home directory of flink distribution.
   FLINK_HOME=${FLINK_HOME:-/opt/module/flink}
   ~
   ```
   
   
   ### Running Command
   
   ```shell
   ./start-seatunnel-flink-15-connector-v2.sh --config 
../config/v2.streaming.conf.template --target  yarn-application --deploy-mode 
run-application
   
   ------------------------------  控制台日志  -----------------------------------
   SLF4J: Class path contains multiple SLF4J bindings.
   SLF4J: Found binding in 
[jar:file:/opt/module/flink/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
   SLF4J: Found binding in 
[jar:file:/opt/module/hadoop/share/hadoop/common/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
   SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an 
explanation.
   SLF4J: Actual binding is of type 
[org.apache.logging.slf4j.Log4jLoggerFactory]
   2024-03-31 11:54:04,385 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli  
              [] - Found Yarn properties file under /tmp/.yarn-properties-lfw.
   2024-03-31 11:54:04,385 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli  
              [] - Found Yarn properties file under /tmp/.yarn-properties-lfw.
   2024-03-31 11:54:04,482 WARN  
org.apache.flink.yarn.configuration.YarnLogConfigUtil        [] - The 
configuration directory ('/opt/module/flink/conf') already contains a LOG4J 
config file.If you want to use logback, then please delete or rename the log 
configuration file.
   2024-03-31 11:54:04,522 INFO  
org.apache.hadoop.yarn.client.DefaultNoHARMFailoverProxyProvider [] - 
Connecting to ResourceManager at hadoop103/192.168.6.103:8032
   2024-03-31 11:54:04,666 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - No path for the flink jar passed. Using the location of 
class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
   2024-03-31 11:54:04,773 INFO  org.apache.hadoop.conf.Configuration           
              [] - resource-types.xml not found
   2024-03-31 11:54:04,774 INFO  
org.apache.hadoop.yarn.util.resource.ResourceUtils           [] - Unable to 
find 'resource-types.xml'.
   2024-03-31 11:54:04,810 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - The configured JobManager memory is 1600 MB. YARN will 
allocate 2048 MB to make up an integer multiple of its minimum allocation 
memory (1024 MB, configured via 'yarn.scheduler.minimum-allocation-mb'). The 
extra 448 MB may not be used by Flink.
   2024-03-31 11:54:04,810 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - The configured TaskManager memory is 1728 MB. YARN will 
allocate 2048 MB to make up an integer multiple of its minimum allocation 
memory (1024 MB, configured via 'yarn.scheduler.minimum-allocation-mb'). The 
extra 320 MB may not be used by Flink.
   2024-03-31 11:54:04,810 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Cluster specification: 
ClusterSpecification{masterMemoryMB=1600, taskManagerMemoryMB=1728, 
slotsPerTaskManager=1}
   2024-03-31 11:54:07,095 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Adding delegation tokens to the AM container.
   2024-03-31 11:54:07,100 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Delegation tokens added to the AM container.
   2024-03-31 11:54:07,104 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Submitting application master application_1711849860491_0007
   2024-03-31 11:54:07,132 INFO  
org.apache.hadoop.yarn.client.api.impl.YarnClientImpl        [] - Submitted 
application application_1711849860491_0007
   2024-03-31 11:54:07,132 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Waiting for the cluster to be allocated
   2024-03-31 11:54:07,134 INFO  org.apache.flink.yarn.YarnClusterDescriptor    
              [] - Deploying cluster, current state ACCEPTED
   ```
   
   
   ### Error Exception
   
   ```log
   ------------------------------------- 报错日志 
------------------------------------
   2024-03-31 11:54:16,244 INFO  
org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils [] - The derived 
from fraction jvm overhead memory (172.800mb (181193935 bytes)) is less than 
its min value 192.000mb (201326592 bytes), min value will be used instead
   2024-03-31 11:54:16,266 INFO  
org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - 
DefaultDispatcherRunner was granted leadership with leader id 
00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess.
   2024-03-31 11:54:16,271 INFO  
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Start SessionDispatcherLeaderProcess.
   2024-03-31 11:54:16,274 INFO  
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - 
Starting resource manager service.
   2024-03-31 11:54:16,284 INFO  
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - 
Resource manager service is granted leadership with session id 
00000000-0000-0000-0000-000000000000.
   2024-03-31 11:54:16,301 INFO  
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Recover all persisted job graphs that are not finished, yet.
   2024-03-31 11:54:16,301 INFO  
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Successfully recovered 0 persisted job graphs.
   2024-03-31 11:54:16,351 WARN  
org.apache.flink.configuration.GlobalConfiguration           [] - Error while 
trying to split key and value in configuration file 
/tmp/hadoop-lfw/nm-local-dir/usercache/lfw/appcache/application_1711849860491_0007/container_1711849860491_0007_01_000001/flink-conf.yaml:10:
 "pipeline.classpaths: "
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: $internal.application.main, 
org.apache.seatunnel.core.starter.flink.SeaTunnelFlink
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: taskmanager.memory.process.size, 1728m
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: taskmanager.bind-host, 0.0.0.0
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: classloader.check-leaked-classloader, false
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: execution.savepoint-restore-mode, NO_CLAIM
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.execution.failover-strategy, region
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.cluster-id, 
application_1711849860491_0007
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.rpc.address, hadoop102
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: execution.target, yarn-application
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.memory.process.size, 1600m
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.rpc.port, 6123
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: rest.bind-address, 0.0.0.0
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.bind-host, 0.0.0.0
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: execution.savepoint.ignore-unclaimed-state, false
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: execution.attached, true
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: internal.cluster.execution-mode, NORMAL
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: $internal.application.program-args, 
--config;../config/v2.streaming.conf.template;--name;SeaTunnel
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: execution.shutdown-on-attached-exit, false
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: pipeline.jars, 
file:/opt/module/seatunnel/starter/seatunnel-flink-15-starter.jar
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: parallelism.default, 1
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: taskmanager.numberOfTaskSlots, 1
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: rest.address, hadoop102
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: $internal.deployment.config-dir, /opt/module/flink/conf
   2024-03-31 11:54:16,352 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: $internal.yarn.log-config-file, 
/opt/module/flink/conf/log4j.properties
   2024-03-31 11:54:16,377 INFO  
org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC 
endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at 
akka://flink/user/rpc/dispatcher_0 .
   2024-03-31 11:54:16,420 INFO  
org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC 
endpoint for 
org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at 
akka://flink/user/rpc/resourcemanager_1 .
   2024-03-31 11:54:16,445 INFO  
org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - 
Starting the resource manager.
   2024-03-31 11:54:16,466 INFO  org.apache.flink.client.ClientUtils            
              [] - Starting program (detached: false)
   2024-03-31 11:54:16,537 INFO  
org.apache.hadoop.yarn.client.DefaultNoHARMFailoverProxyProvider [] - 
Connecting to ResourceManager at hadoop103/192.168.6.103:8030
   2024-03-31 11:54:16,845 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - 
   
   
===============================================================================
   
   
   2024-03-31 11:54:16,846 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - Fatal Error, 
   
   2024-03-31 11:54:16,846 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - Please submit bug report in 
https://github.com/apache/seatunnel/issues
   
   2024-03-31 11:54:16,846 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - Reason:ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel 
read file '../config/v2.streaming.conf.template' failed, because it not 
existed.] 
   
   2024-03-31 11:54:16,858 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - Exception 
StackTrace:org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: 
ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel read file 
'../config/v2.streaming.conf.template' failed, because it not existed.]
        at 
org.apache.seatunnel.common.exception.CommonError.fileNotExistFailed(CommonError.java:75)
        at 
org.apache.seatunnel.core.starter.utils.FileUtils.checkConfigExist(FileUtils.java:66)
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:50)
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
        at 
org.apache.seatunnel.core.starter.flink.SeaTunnelFlink.main(SeaTunnelFlink.java:34)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
        at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
        at 
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98)
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$2(ApplicationDispatcherBootstrap.java:254)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:171)
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$withContextClassLoader$0(ClassLoadingUtils.java:41)
        at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
        at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
        at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
        at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
    
   2024-03-31 11:54:16,858 ERROR org.apache.seatunnel.core.starter.SeaTunnel    
              [] - 
   
===============================================================================
   
   
   
   2024-03-31 11:54:16,859 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(CompletableFuture.java:292)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943) 
~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 
~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
 ~[?:1.8.0_212]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:337)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$2(ApplicationDispatcherBootstrap.java:254)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
~[?:1.8.0_212]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
~[?:1.8.0_212]
        at 
org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:171)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$withContextClassLoader$0(ClassLoadingUtils.java:41)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 
[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
 [flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 
[?:1.8.0_212]
        at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 
[?:1.8.0_212]
        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 
[?:1.8.0_212]
        at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) 
[?:1.8.0_212]
   Caused by: 
org.apache.flink.client.deployment.application.ApplicationExecutionException: 
Could not execute application.
        ... 13 more
   Caused by: org.apache.flink.client.program.ProgramInvocationException: The 
main method caused an error: ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel 
read file '../config/v2.streaming.conf.template' failed, because it not 
existed.]
        at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) 
~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
 ~[flink-dist-1.16.3.jar:1.16.3]
        ... 12 more
   Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: 
ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel read file 
'../config/v2.streaming.conf.template' failed, because it not existed.]
        at 
org.apache.seatunnel.common.exception.CommonError.fileNotExistFailed(CommonError.java:75)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.utils.FileUtils.checkConfigExist(FileUtils.java:66)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:50)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) 
~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.flink.SeaTunnelFlink.main(SeaTunnelFlink.java:34)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
~[?:1.8.0_212]
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
~[?:1.8.0_212]
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 ~[?:1.8.0_212]
        at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_212]
        at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) 
~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
 ~[flink-dist-1.16.3.jar:1.16.3]
        ... 12 more
   2024-03-31 11:54:16,902 ERROR 
org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Fatal error 
occurred in the cluster entrypoint.
   java.util.concurrent.CompletionException: 
org.apache.flink.client.deployment.application.ApplicationExecutionException: 
Could not execute application.
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943) 
~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
 ~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 
~[?:1.8.0_212]
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
 ~[?:1.8.0_212]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:337)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$2(ApplicationDispatcherBootstrap.java:254)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
~[?:1.8.0_212]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
~[?:1.8.0_212]
        at 
org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:171)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$withContextClassLoader$0(ClassLoadingUtils.java:41)
 ~[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 
[flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
 [flink-rpc-akka_d3432dff-6e6b-4afc-8004-a5788cc1707b.jar:1.16.3]
        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 
[?:1.8.0_212]
        at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 
[?:1.8.0_212]
        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 
[?:1.8.0_212]
        at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) 
[?:1.8.0_212]
   Caused by: 
org.apache.flink.client.deployment.application.ApplicationExecutionException: 
Could not execute application.
        ... 13 more
   Caused by: org.apache.flink.client.program.ProgramInvocationException: The 
main method caused an error: ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel 
read file '../config/v2.streaming.conf.template' failed, because it not 
existed.]
        at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) 
~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
 ~[flink-dist-1.16.3.jar:1.16.3]
        ... 12 more
   Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: 
ErrorCode:[COMMON-22], ErrorDescription:[SeaTunnel read file 
'../config/v2.streaming.conf.template' failed, because it not existed.]
        at 
org.apache.seatunnel.common.exception.CommonError.fileNotExistFailed(CommonError.java:75)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.utils.FileUtils.checkConfigExist(FileUtils.java:66)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:50)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) 
~[seatunnel-flink-15-starter.jar:2.3.4]
        at 
org.apache.seatunnel.core.starter.flink.SeaTunnelFlink.main(SeaTunnelFlink.java:34)
 ~[seatunnel-flink-15-starter.jar:2.3.4]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
~[?:1.8.0_212]
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
~[?:1.8.0_212]
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 ~[?:1.8.0_212]
        at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_212]
        at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
 ~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) 
~[flink-dist-1.16.3.jar:1.16.3]
        at 
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:301)
 ~[flink-dist-1.16.3.jar:1.16.3]
        ... 12 more
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   flink1.16.3
   
   ### Java or Scala Version
   
   java 8 / scala-2.12.15
   
   ### Screenshots
   
   图1:任务综合情况
   
![4](https://github.com/apache/seatunnel/assets/82995456/185c4f28-f4d7-46af-9738-901d35413930)
   
   图2:具体日志报错点
   
![5](https://github.com/apache/seatunnel/assets/82995456/8c71ff7e-010b-4314-842e-c7e68cba0c9d)
   
   
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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]

Reply via email to