org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Could not deploy Yarn job cluster.
Caused by: org.apache.flink.client.deployment.ClusterDeploymentException: Could not deploy Yarn job cluster.
Caused by: org.apache.flink.yarn.YarnClusterDescriptor$YarnDeploymentException: The YARN application unexpectedly switched to state FAILED during deployment.
Diagnostics from YARN: Application application_1640140324841_0003 failed 1 times (global limit =4; local limit is =1) due to AM Container for appattempt_1640140324841_0003_000001 exited with exitCode: 1
Failing this attempt.Diagnostics: [2021-12-22 11:23:34.422]Exception from container-launch.
Container id: container_e44_1640140324841_0003_01_000001
Exit code: 1
Shell output: main : command provided 1
main : run as user is etl_admin
main : requested yarn user is etl_admin
Getting exit code file…
Creating script paths…
Writing pid file…
Writing to tmp file /data1/yarn/nm/nmPrivate/application_1640140324841_0003/container_e44_1640140324841_0003_01_000001/container_e44_1640140324841_0003_01_000001.pid.tmp
Writing to cgroup task files…
Creating local dirs…
Launching container…
Solution:
Look is the flink version of the idea is 1.11.0, the flink version on the cluster is 1.13.1
Directly upgrade the flink version in the idea to 1.13.1, done!
Read More:
- [Solved] org.apache.flink.client.program.ProgramInvocationException: The main method caused an error
- [Solved] Maven Publish Error: Failed to execute goal org.apache.maven.pluginsmaven-deploy-plugin2.8.2deploy
- [Solved] Hadoop Error: Exception in thread “main“ java.io.IOException: Error opening job jar: /usr/local/hadoop-2.
- [Solved] Solr8 establishes the cluster node as active, but the query reports an error
- [Solved] error: method does not override or implement a method from a supertype
- [Solved] Zookeeper cluster error: Error contacting service It is probably not running. (alicloud server)
- Problems and causes of Java’s main function format (public static void main (string args()))
- Java Error: No enclosing instance of type Main is accessible. Must qualify the allocation with an encl
- Java Running Error: Could not find or load main class
- [Solved] Springboot Project Start Error: An attempt was made to call the method com.google.common.collect.Multimaps.asMap
- Code case of XXL job executor
- [Solved] Springboot Deploy Error: Input length = 1 or Input length = 2
- Abstract method and static method of java interface
- [Solved] Could not find resource COM / atguigu / Dao / studentdao.xm, the mapper file for storing SQL statements could not be found and an error occurred
- [Solved] “status“:405,“error“ Request method ‘POST‘ not supported“
- [Solved] Error: caused by: java.net.bindexception: the address is already in use
- JAVA: How to use the third-party font library method (using the third-party TTF / TTC font library method)
- [Solved] fasterxml ToStringSerializerBase Error: Caused by: java.lang.NoClassDefFoundError…
- Caused by: java.lang.IllegalStateException (How to Fix)
- [Solved] Docker Elasticsearch8.4.0 Error: Exception in thread “main” java.nio.file.FileSystemException