开发者社区> 问答> 正文

flink1.11.1使用Table API Hive方言的executSql报错

大家好: 我基于Flink1.11.1的表API使用Hive方言,调用executSql方法后报错,触发信息如下: org.apache.flink.client.program.ProgramInvocationException:主要方法 导致错误:无法执行sql 在 org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:302) ~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.client.program.PackagedProgram .invokeInteractiveModeForExecution(PackagedProgram.java:198) ~[flink-dist_2. 11-1.11.1.jar:1.11.1] 在 org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java: 149)~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.client.deployment.application。 DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:78) ~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.client.deployment.application。 DetachedApplicationRunner.run(DetachedApplicationRunner.java:67) ~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.runtime.webmonitor.handlers.JarRunHandler .lambda$handleRequest$0(JarRunHandler.java:100) ~[flink-dist_2.11-1.11.1 .jar:1.11.1] 在 java.util.concurrent.CompletableFuture$AsyncSupply.run( CompletableFuture.java:1604) [?:1.8.0_242] 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java: [511] [?:1.8.0_242] 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_242 ] 在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask .access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_242] 在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask .run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_242] 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor .java:1149) [?:1.8.0_242] 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:624) [?:1.8.0_242] 在 java.lang.Thread.run(Thread.java:748) [?:1.8.0_242] 引起:org.apache.flink.table.api.TableException: Failed to execute sql 在 org.apache.flink.table.api.internal.TableEnvironmentImpl .executeInternal(TableEnvironmentImpl.java:747) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] 在 org.apache.flink.table.api.internal.TableEnvironmentImpl .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] 在 org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] 在 org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. 0_242] 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl .java:62) ~[?:1.8.0_242] 在 sun.reflect.DelegatingMethodAccessorImpl.invoke( DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] 在 java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] 在 org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1] ……还有 13 个 引起:java.lang.IllegalArgumentException:Job client must be a 协调请求网关。这是一个错误。 在 org.apache.flink.util.Preconditions.checkArgument(Preconditions.java: 139)~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.streaming.api.operators.collect.CollectResultFetcher .setJobClient(CollectResultFetcher.java:97) ~[flink-dist_2.11-1.11.1.jar: 1.11.1] 在 org.apache.flink.streaming.api.operators.collect。 CollectResultIterator.setJobClient(CollectResultIterator.java:84) ~[flink-dist_2.11-1.11.1.jar:1.11.1] 在 org.apache.flink.table.planner.sinks.SelectTableSinkBase .setJobClient(SelectTableSinkBase.java:81) ~[flink-table-blink_2.11-1.11.1 .jar:1.11.1] 在 org.apache.flink.table.api.internal.TableEnvironmentImpl .executeInternal(TableEnvironmentImpl.java:737) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] 在 org.apache.flink.table.api.internal.TableEnvironmentImpl .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] 在 org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] 在 org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. 0_242] 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl .java:62) ~[?:1.8.0_242] 在 sun.reflect.DelegatingMethodAccessorImpl.invoke( DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] 在 java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] 在 org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1]

*核心错误 作业客户端必须是 CoordinationRequestGateway。这是一个错误。 难道这是一个Bug吗?*来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-07 10:07:47 1488 0
1 条回答
写回答
取消 提交回答
  • 你的包是完整的flink-1.11.1的包吗? 例如检查一下 ClusterClientJobClientAdapter 这个类是否继承了 CoordinationRequestGateway ?*来自志愿者整理的flink邮件归档

    2021-12-07 11:43:29
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Spring Boot2.0实战Redis分布式缓存 立即下载
CUDA MATH API 立即下载
API PLAYBOOK 立即下载