Flink这是啥原因啊?-[阿里云_云淘科技]

Flink这是啥原因啊?Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to wait job finish at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105) at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84) … 4 more Caused by: org.apache.flink.table.api.TableException: Failed to wait job finish at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:85) at org.apache.flink.table.api.internal.InsertResultProvider.access$200(InsertResultProvider.java:37) at org.apache.flink.table.api.internal.InsertResultProvider$Iterator.hasNext(InsertResultProvider.java:106) at org.apache.flink.table.utils.print.RawContentStyle.print(RawContentStyle.java:39) at org.apache.flink.table.api.internal.TableResultImpl.print(TableResultImpl.java:153) at com.ums.amr.flink.search.Search.main(Search.java:118) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) … 7 more Caused by: org.apache.flink.util.FlinkRuntimeException: The Job Result cannot be fetched through the Job Client when in Web Submission. at org.apache.flink.client.deployment.application.WebSubmissionJobClient.getJobExecutionResult(WebSubmissionJobClient.java:92) at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:83) … 17 more

以下为热心网友提供的参考意见

这通常是由于 Flink 程序执行失败导致的。你可以通过以下方式排查错误:

检查 Flink 的运行日志,看看是否有相关的错误信息。
检查 Flink 程序的代码,看看是否有逻辑错误。
检查 Flink 程序的依赖项,看看是否有版本不匹配的问题。
检查 Flink 程序的运行环境,看看是否有配置不正确的问题。
如果您仍然无法解决问题,可以联系 Flink 的技术支持寻求帮助。

本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/18638.html

(0)
匿名
上一篇 2023年12月25日
下一篇 2023年12月25日

相关推荐

新手站长从“心”出发,感谢16年您始终不离不弃。