您好，
针对sql-client运行在yarn-session模式报错，现补充相关日志报错信息：
2023-07-15 18:43:21,503 INFO org.apache.flink.table.client.cli.CliClient
[] - Command history file path: /root/.flink-sql-history
2023-07-15 18:43:28,225 INFO org.apache.flink.table.catalog.CatalogManager
[] - Set the current default database as [flink] in the current
default catalog [myhive].
2023-07-15 18:43:38,410 WARN
org.apache.flink.connector.kafka.source.KafkaSourceBuilder [] - Offset commit
on checkpoint is disabled because group.id is not specified
2023-07-15 18:43:39,986 WARN
org.apache.flink.connector.kafka.source.KafkaSourceBuilder [] - Offset commit
on checkpoint is disabled because group.id is not specified
2023-07-15 18:43:40,605 WARN
org.apache.flink.yarn.configuration.YarnLogConfigUtil [] - The
configuration directory ('/usr/local/flink-1.14.5/conf') already contains a
LOG4J config file.If you want to use logback, then please delete or rename the
log configuration file.
2023-07-15 18:43:40,676 INFO org.apache.hadoop.yarn.client.RMProxy
[] - Connecting to ResourceManager at /0.0.0.0:8032
2023-07-15 18:43:40,788 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
2023-07-15 18:43:40,791 WARN org.apache.flink.table.client.cli.CliClient
[] - Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Could not execute
SQL statement.
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:224)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.callInserts(CliClient.java:571)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.callInsert(CliClient.java:560)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:420)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_231]
at
org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
[flink-sql-client_2.11-1.14.5.jar:1.14.5]
Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:791)
~[flink-table_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:754)
~[flink-table_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeModifyOperations$4(LocalExecutor.java:222)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:222)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
... 12 more
Caused by: java.lang.IllegalStateException
at
org.apache.flink.util.Preconditions.checkState(Preconditions.java:177)
~[flink-dist_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.execute(AbstractSessionClusterExecutor.java:72)
~[flink-clients_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2042)
~[flink-dist_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95)
~[flink-table_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:773)
~[flink-table_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:754)
~[flink-table_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeModifyOperations$4(LocalExecutor.java:222)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:222)
~[flink-sql-client_2.11-1.14.5.jar:1.14.5]
在 2023-07-10 10:53:33，"Shammon FY" <zjur...@gmail.com> 写道：
>Hi,
>
>邮件里的图片看不到
>
>Best,
>Shammon FY
>
>On Sun, Jul 9, 2023 at 7:30 PM 杨东树 <yangdongshu_l...@163.com> wrote:
>
>> 各位好，
>> 目前我在使用flink1.14.5版本的sql-client on
>> yarn-session模式时，发现无法正常执行sql任务，日志报如下错误，希望能得到指导，谢谢：
>> 背景信息：
>> 1、当flink配置execution.target:
>> yarn-per-job时，随后进入sql-client执行sql任务，可正常执行。
>> 2、当flink配置execution.target: yarn-session，并启动flink
>> yarn-session集群，随后进入sql-client执行同样的sql任务，报上图中的错误。
>>
