Hi,all:
本人基于Flink1.11.1的table API使用Hive方言,调用executSql方法后报错,堆栈信息如下: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to execute sql at org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:302) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.client.program.PackagedProgram .invokeInteractiveModeForExecution(PackagedProgram.java:198) ~[flink-dist_2. 11-1.11.1.jar:1.11.1] at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java: 149) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.client.deployment.application. DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:78) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.client.deployment.application. DetachedApplicationRunner.run(DetachedApplicationRunner.java:67) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler .lambda$handleRequest$0(JarRunHandler.java:100) ~[flink-dist_2.11-1.11.1 .jar:1.11.1] at java.util.concurrent.CompletableFuture$AsyncSupply.run( CompletableFuture.java:1604) [?:1.8.0_242] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java: 511) [?:1.8.0_242] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_242 ] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask .access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_242] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask .run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_242] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor .java:1149) [?:1.8.0_242] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:624) [?:1.8.0_242] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242] Caused by: org.apache.flink.table.api.TableException: Failed to execute sql at org.apache.flink.table.api.internal.TableEnvironmentImpl .executeInternal(TableEnvironmentImpl.java:747) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. 0_242] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl .java:62) ~[?:1.8.0_242] at sun.reflect.DelegatingMethodAccessorImpl.invoke( DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] at org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1] ... 13 more Caused by: java.lang.IllegalArgumentException: Job client must be a CoordinationRequestGateway. This is a bug. at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java: 139) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher .setJobClient(CollectResultFetcher.java:97) ~[flink-dist_2.11-1.11.1.jar: 1.11.1] at org.apache.flink.streaming.api.operators.collect. CollectResultIterator.setJobClient(CollectResultIterator.java:84) ~[flink-dist_2.11-1.11.1.jar:1.11.1] at org.apache.flink.table.planner.sinks.SelectTableSinkBase .setJobClient(SelectTableSinkBase.java:81) ~[flink-table-blink_2.11-1.11.1 .jar:1.11.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl .executeInternal(TableEnvironmentImpl.java:737) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- 1.11.1.jar:1.11.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. 0_242] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl .java:62) ~[?:1.8.0_242] at sun.reflect.DelegatingMethodAccessorImpl.invoke( DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] at org.apache.flink.client.program.PackagedProgram.callMainMethod( PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1] * 核心错误 `Job client must be a CoordinationRequestGateway. This is a bug.` 请问这是一个Bug吗? |
你的包是完整的flink-1.11.1的包吗?
例如 check一下 ClusterClientJobClientAdapter 这个类是否继承 CoordinationRequestGateway ? shimin huang <[hidden email]> 于2020年7月28日周二 上午11:21写道: > Hi,all: > 本人基于Flink1.11.1的table API使用Hive方言,调用executSql方法后报错,堆栈信息如下: > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: Failed to execute sql > at org.apache.flink.client.program.PackagedProgram.callMainMethod( > PackagedProgram.java:302) ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at org.apache.flink.client.program.PackagedProgram > .invokeInteractiveModeForExecution(PackagedProgram.java:198) > ~[flink-dist_2. > 11-1.11.1.jar:1.11.1] > at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java: > 149) ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at org.apache.flink.client.deployment.application. > DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:78) > ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at org.apache.flink.client.deployment.application. > DetachedApplicationRunner.run(DetachedApplicationRunner.java:67) > ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler > .lambda$handleRequest$0(JarRunHandler.java:100) ~[flink-dist_2.11-1.11.1 > .jar:1.11.1] > at java.util.concurrent.CompletableFuture$AsyncSupply.run( > CompletableFuture.java:1604) [?:1.8.0_242] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java: > 511) [?:1.8.0_242] > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > [?:1.8.0_242 > ] > at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask > .access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_242] > at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask > .run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_242] > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor > .java:1149) [?:1.8.0_242] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor > .java:624) [?:1.8.0_242] > at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242] > Caused by: org.apache.flink.table.api.TableException: Failed to execute sql > at org.apache.flink.table.api.internal.TableEnvironmentImpl > .executeInternal(TableEnvironmentImpl.java:747) ~[flink-table-blink_2.11- > 1.11.1.jar:1.11.1] > at org.apache.flink.table.api.internal.TableEnvironmentImpl > .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- > 1.11.1.jar:1.11.1] > at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( > TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] > at org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. > 0_242] > at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl > .java:62) ~[?:1.8.0_242] > at sun.reflect.DelegatingMethodAccessorImpl.invoke( > DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] > at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] > at org.apache.flink.client.program.PackagedProgram.callMainMethod( > PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1] > ... 13 more > Caused by: java.lang.IllegalArgumentException: Job client must be a > CoordinationRequestGateway. This is a bug. > at > org.apache.flink.util.Preconditions.checkArgument(Preconditions.java: > 139) ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher > .setJobClient(CollectResultFetcher.java:97) ~[flink-dist_2.11-1.11.1.jar: > 1.11.1] > at org.apache.flink.streaming.api.operators.collect. > CollectResultIterator.setJobClient(CollectResultIterator.java:84) > ~[flink-dist_2.11-1.11.1.jar:1.11.1] > at org.apache.flink.table.planner.sinks.SelectTableSinkBase > .setJobClient(SelectTableSinkBase.java:81) ~[flink-table-blink_2.11-1.11.1 > .jar:1.11.1] > at org.apache.flink.table.api.internal.TableEnvironmentImpl > .executeInternal(TableEnvironmentImpl.java:737) ~[flink-table-blink_2.11- > 1.11.1.jar:1.11.1] > at org.apache.flink.table.api.internal.TableEnvironmentImpl > .executeOperation(TableEnvironmentImpl.java:1069) ~[flink-table-blink_2.11- > 1.11.1.jar:1.11.1] > at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql( > TableEnvironmentImpl.java:690) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] > at org.forchange.online.etl.h2h.Prod2Poc.main(Prod2Poc.java:46) ~[?:?] > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8. > 0_242] > at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl > .java:62) ~[?:1.8.0_242] > at sun.reflect.DelegatingMethodAccessorImpl.invoke( > DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_242] > at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242] > at org.apache.flink.client.program.PackagedProgram.callMainMethod( > PackagedProgram.java:288) ~[flink-dist_2.11-1.11.1.jar:1.11.1] > > > * 核心错误 > `Job client must be a CoordinationRequestGateway. This is a bug.` > 请问这是一个Bug吗? > |
Free forum by Nabble | Edit this page |