使用SQL-CLI向Standalone集群提交任务报错，Yarn应用已停止

按照Apache Flink 1.16官方文档示例操作，通过SQL-CLI向Standalone集群提交任务时出现报错，错误截图如下：

具体报错堆栈信息：

org.apache.flink.table.client.gateway.SqlExecutionException: Could not execute SQL statement.
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:208) ~[flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQuery(LocalExecutor.java:228) ~[flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:542) ~[flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:446) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:372) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.getAndExecuteStatements(CliClient.java:329) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:280) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:228) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) [flink-sql-client-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) [flink-sql-client-1.16.1.jar:1.16.1]
Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:903) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1382) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:206) ~[flink-sql-client-1.16.1.jar:1.16.1]
... 11 more
Caused by: org.apache.flink.client.deployment.ClusterRetrieveException: Couldn't retrieve Yarn cluster
at org.apache.flink.yarn.YarnClusterDescriptor.retrieve(YarnClusterDescriptor.java:419) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.yarn.YarnClusterDescriptor.retrieve(YarnClusterDescriptor.java:139) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.execute(AbstractSessionClusterExecutor.java:80) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95) ~[?:?]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:884) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1382) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:206) ~[flink-sql-client-1.16.1.jar:1.16.1]
... 11 more
Caused by: java.lang.RuntimeException: The Yarn application application_1678676822488_0188 doesn't run anymore.
at org.apache.flink.yarn.YarnClusterDescriptor.retrieve(YarnClusterDescriptor.java:405) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.yarn.YarnClusterDescriptor.retrieve(YarnClusterDescriptor.java:139) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.execute(AbstractSessionClusterExecutor.java:80) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188) ~[flink-dist-1.16.1.jar:1.16.1]
at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95) ~[?:?]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:884) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1382) ~[flink-table-api-java-uber-1.16.1.jar:1.16.1]
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:206) ~[flink-sql-client-1.16.1.jar:1.16.1]
... 11 more

问题分析 #

从堆栈核心报错The Yarn application application_1678676822488_0188 doesn't run anymore可知，SQL-CLI尝试连接Yarn集群，但你实际要提交到Standalone集群，说明SQL-CLI的集群配置错误，指向了Yarn而非Standalone。

解决方案 #

• 检查SQL-CLI配置文件（默认是conf/sql-client-defaults.yaml），修改为Standalone集群配置：

  execution:
    target: remote
    deployment:
      address: <JobManager主机名>:<端口> # 替换为你的Standalone JobManager地址，默认端口8081
  

• 启动SQL-CLI时，明确指定Standalone配置文件（若单独配置）：

  ./bin/sql-client.sh -d conf/sql-client-standalone.yaml
  

• 确认Standalone集群的JobManager处于运行状态，且SQL-CLI所在机器能连通JobManager的网络端口。
• 清理残留的Yarn会话配置，确保无其他配置覆盖Standalone设置。

内容的提问来源于stack exchange，提问作者Paddy