问题一:Flink这是啥错误呢?
Flink这是啥错误呢?
参考回答:
你这集群搭的有问题,很明显的错误,访问远程task出现了一个127.0.0.1 task节点的配置文件要配置自己节点上的ip,其他设置都一样,唯独这个地方必须得改。这是flink 1.15版本以后才精确的
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582449
问题二:大家采集flink指标写入influxdb有遇到这个问题吗?
大家采集flink指标写入influxdb有遇到这个问题吗?
参考回答:
采集 Flink 指标写入 InfluxDB 时,可能会遇到以下问题:
无法访问 InfluxDB。如果 InfluxDB 的 IP 地址或端口号不正确,或者 InfluxDB 没有启动,则可能会出现此问题。
无法解析 InfluxDB 的数据库或表。如果 InfluxDB 的数据库或表不存在,或者数据库或表的名称不正确,则可能会出现此问题。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582446
问题三:为什么flink提供的demo代码都执行不了?
为什么flink提供的demo代码都执行不了?Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:974)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1422)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:765)
at org.apache.flink.table.examples.java.basics.WordCountSQLExample.main(WordCountSQLExample.java:35)
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: java.lang.IllegalArgumentException: Job client must be a CoordinationRequestGateway. This is a bug.
at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.setJobClient(CollectResultFetcher.java:90)
at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.setJobClient(CollectResultIterator.java:101)
at org.apache.flink.table.planner.connectors.CollectDynamicSink$CollectResultProvider.setJobClient(CollectDynamicSink.java:167)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:957)
参考回答:
楼主你好,看了你的报错信息,这个错误是在执行Flink SQL时出现了问题。可能是Flink版本不兼容造成的,请确认使用的Flink版本是否与示例代码的版本匹配。
还有就是示例代码可能依赖于一些特定的依赖包,请确保项目依赖中包含了示例代码所需的所有依赖包,并且版本也要匹配。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582445
问题四:我这flinkHA集群出现这么个问题?
我这flinkHA集群出现这么个问题?我不知道是不是zookeeper集群有问题引起的,谁遇到过可以分享一下 No JAAS configuration section named 'Client
was found in specified JAAS configuration file:!/tmp/jaas-3331740396007956723, conf'.
Wil1 continue connection to Zookeeper gerver without
SASL authentication, if Zookeeper server allows it.1
参考回答:
"你的 jaas 文件里面没有一个叫Client 的配置
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582444
问题五: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 的技术支持寻求帮助。
关于本问题的更多回答可点击原文查看: