Flink启动报错could not be determined automatically

今天发布Flink应用，报如下错误：

The return type of function 'main(RyeCollectorLauncher.java:77)' could not be determined automatically, due to type erasure. You can give type information hints by using the returns(...) method on the result of the transformation call, or by letting your function implement the 'ResultTypeQueryable' interface.org.apache.flink.streaming.api.transformations.StreamTransformation.getOutputType(StreamTransformation.java:420)org.apache.flink.streaming.api.datastream.DataStream.getType(DataStream.java:175)org.apache.flink.streaming.api.datastream.DataStream.union(DataStream.java:217)com.mogujie.traffic.rye.anchor.flink.collector.RyeCollectorLauncher.main(RyeCollectorLauncher.java:104)

根据错误信心定位到出错位置：

根据错误信息You can give type information hints by using the returns，只需要在后面调用returns方法，然后指明其返回类型即可解决。

问题已经解决，这里简单记录下，希望可以帮到各位朋友！！！

补充：
报错：

2019-07-30 11:36:46,193 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Could not start cluster entrypoint YarnJobClusterEntrypoint.
org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint YarnJobClusterEntrypoint.at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:181)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:517)at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:102)
Caused by: java.lang.Exception: Could not create actor systemat org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:276)at org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:162)at org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:121)at org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:96)at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.createRpcService(AkkaRpcServiceUtils.java:78)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createRpcService(ClusterEntrypoint.java:284)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:255)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:207)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:163)at java.security.AccessController.doPrivileged(Native Method)at javax.security.auth.Subject.doAs(Subject.java:422)at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:162)... 2 more
Caused by: java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;at org.apache.flink.runtime.akka.AkkaUtils$.getRemoteAkkaConfig(AkkaUtils.scala:471)at org.apache.flink.runtime.akka.AkkaUtils$.getAkkaConfig(AkkaUtils.scala:218)at org.apache.flink.runtime.akka.AkkaUtils.getAkkaConfig(AkkaUtils.scala)at org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:256)... 15 more

出现这种问题是程序中的Scala版本和线上集群使用的版本产生冲突，因此只需要更换Scala版本即可。

Flink启动报错could not be determined automatically相关推荐

Flink程序启动报错could not be determined automatically
could not be determined automatically 通过idea中的报错可以定位到错误位置修改为如下的方式即可,根据你的返回值来定的,不要写和我一样的哦!!!
【Flink】Flink启动报错 BindException: Could not start rest endpoint on any port in port range 7089
1.背景 Flink界面启动报错如下 2020-05-15 13:27:47,001 INFO org.apache.flink.client.cli.C
【Flink】Flink 启动报错 DirectoryNotEmptyException Could not close resource
美图 1.背景 windows下开发Flink程序,启动的时候报错如下,下次再次启动的时候就不报错了 org.apache.flink.util.FlinkException: Could not c ...
[故障解决]图文:python启动报错:api-ms-win-crt-runtime-l1-1-0.dll丢失解决
python启动报错:api-ms-win-crt-runtime-l1-1-0.dll丢失解决环境 Windows 7 SP1 x64 python3.6.1 报错解决办法 1.下载VC red ...
oracle log block size,案例:Oracle无法启动报错ORA-00218: block size 0 重建控制文件
天萃荷净 oracle数据库无法启动报错ORA-00218故障,通过重建控制文件解决文件损坏问题遇到一个案例在数据库启动的时候报ORA-00218错误,而这个故障的引起原因是因为重建控制文件的时候, ...
linux重启was控制台报错,Linux非WAS部署，启动报错Cannot run program \lsb_release\
Linux非WAS部署,启动报错Cannot run program "lsb_release" 已确认 tools.jar 文件是当前 linux 中的 jdk 下的 jar 文 ...
DRP问题集结（一）-Tomcat无法启动,报错java.lang.NoClassDefFoundError: org/apache/juli/logging/LogFactory...
问题一: Tomcat无法启动,报错java.lang.NoClassDefFoundError: org/apache/juli/logging/LogFactory 问题二:[Error]Jav ...
mysql安装教程博音网_RTSP视频平台EasyNVR使用mysql数据源启动报错unknow drivermysql优化...
原标题:RTSP视频平台EasyNVR使用mysql数据源启动报错unknow driver"mysql"优化我们上一篇讲了TSINGSEE青犀视频开发的视频平台默认都是使用的s ...
程序启动报错:ORA-12505；PL/SQL却可以登录的解决方法
程序启动报错:ORA-12505;PL/SQL却可以登录的解决方法参考文章: (1)程序启动报错:ORA-12505;PL/SQL却可以登录的解决方法 (2)https://www.cnblogs. ...

Flink启动报错could not be determined automatically

Flink启动报错could not be determined automatically相关推荐

最新文章

热门文章