flink开发过程中遇到的问题怎么解决
发表于:2025-01-23 作者:千家信息网编辑
千家信息网最后更新 2025年01月23日,这篇文章主要介绍"flink开发过程中遇到的问题怎么解决",在日常操作中,相信很多人在flink开发过程中遇到的问题怎么解决问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答
千家信息网最后更新 2025年01月23日flink开发过程中遇到的问题怎么解决类转换异常
这种问题一般发生在将flink程序部署到yarn集群的时候,由于flink启动的时候会加载hadoop下面的jar包,加到自己的classpath里,如果hadoop的jar包和自己flink工程的jar包版本不一致就会导致这个问题,解决办法:排除自己工程中的hadoop相关的jar,打包的时候不要打进来.
这篇文章主要介绍"flink开发过程中遇到的问题怎么解决",在日常操作中,相信很多人在flink开发过程中遇到的问题怎么解决问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答"flink开发过程中遇到的问题怎么解决"的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
类转换异常
cannot be cast to com.google.protobuf.Message
Caused by: java.lang.ClassCastException: org.apache.hadoop.yarn.proto.YarnServiceProtos$RegisterApplicationMasterRequestProto cannot be cast to com.google.protobuf.Message
at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:227)
at com.sun.proxy.$Proxy14.registerApplicationMaster(Unknown Source)
at org.apache.hadoop.yarn.api.impl.pb.client.ApplicationMasterProtocolPBClientImpl.registerApplicationMaster(ApplicationMasterProtocolPBClientImpl.java:106)
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.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:256)
at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:104)
at com.sun.proxy.$Proxy15.registerApplicationMaster(Unknown Source)
at org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.registerApplicationMaster(AMRMClientImpl.java:222)
at org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.registerApplicationMaster(AMRMClientImpl.java:214)
at org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl.registerApplicationMaster(AMRMClientAsyncImpl.java:138)
at org.apache.flink.yarn.YarnResourceManager.createAndStartResourceManagerClient(YarnResourceManager.java:205)
at org.apache.flink.yarn.YarnResourceManager.initialize(YarnResourceManager.java:234)
... 11 common frames omitted
org.apache.hadoop
hadoop-common
${hadoop.version}
provided
提示,有可能你没有显式的引入hadoop-common、hadoop-hdfs这样的jar包,但是你引入了hbase的jar包,因为hbase会引入hdfs相关的jar包,也会导致类似的错误。
local class incompatible
org.apache.flink.table.api.StreamQueryConfig; local class incompatible: stream classdesc serialVersionUID = XXX, local class serialVersionUID = -XXX
在提交flink程序的时候如果出现这种情况一般是由于jar包冲突导致的,可能是某一个jar的冲突、也可能是scala的版本不一致导致的,比如你的flink集群的scala是2.11,你的程序的scala版本是2.12
到此,关于"flink开发过程中遇到的问题怎么解决"的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注网站,小编会继续努力为大家带来更多实用的文章!
问题
过程
开发
时候
学习
版本
程序
一致
工程
更多
集群
冲突
帮助
实用
接下来
办法
情况
文章
方法
理论
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
向服务器发送字节码
时间同步服务器有哪些功能
英皇网络技术有限公司
织梦链接数据库的页面在哪
浙江一站式软件开发流程
软件开发需要哪些书籍
市扶贫办软件开发
服务器升级公告
云桌面签名服务器怎么删除
在数据库中插入多行数据
幼儿园网络安全主题活动记录
清镇网络安全系统费用
山东高中网络技术应用试题
软件开发计划重要事项
冰川网络安全科技馆
轮回服几个服务器的任务
怎么看网页用的数据库
护苗 网络安全观后感
楼楼服务器下载
重庆泛在网络技术有限公司
培训机构嵌入式软件开发
广东标准网络技术优化
方舟手机版进服务器的教程
币软件开发
天津农业银行软件开发岗
社区群租治理数据库
衡阳软件开发培训有哪些
数据库引擎打不开文件mdb
网络安全与数字签名相关技术论文
部队手机网络安全防范 六查六防