map算子内部使用fastjson

在map算子内部进行JSON.parseObject, idea 没有错误信息，放到集群上提示找不到fastjson/JSON, 请问idea和集群分别怎么解决呢？

鋆坤 2021-11-24

源自：Flink快速上手篇 1-1 快速了解Flink

7

收起

1回答

徐老师 2021-11-24 18:12:34

在打jar包提交到集群执行的时候需要吧json依赖打进去

提问者鋆坤 #1

已经使用maven插件打到里面了……还是找不到

2021-11-24 18:36:27
提问者鋆坤 #2

而且在idea运行，也是不成功，但是没有异常输出，一直重复消费Kafka消息，也是因为json转换失败

2021-11-24 18:38:45
徐老师回复提问者鋆坤 #3

1：到生成的jar包中确认一下是否有这个json的依赖，如果提示找不到fastjson，应该是没有打进去。
2：idea中，数据消费出来后，见数据打印一下，看看数据有什么问题，尝试换一个topic，重新输入正确的json数据

2021-11-24 20:29:11

相似问题

jackson与fastjson有什么区别，这里为什么不使用fastjson进行json序列化？

关于RDD算子

接口抽象内部类

关于内部类的具体运用

关于内部类被 static 修饰

登录后可查看更多问答，登录/注册

大数据工程师

参与学习 1186 人
提交作业 6197 份
解答问题 1201 个

不用Java初级内容充数！不用与大数据岗位无关内容占课时！我们做的就是“精华版”大数据课程

本课精华内容

问答作业

老师，每个比较大的文件都会分割成块保存在DataNode中，那就说一个datanode坏了导致整个文件不可用，这样不就减低了可靠性吗？

56 2

对多个executor并行处理，对数据进行去重，这样会不会有重复数据

32 1

数据倾斜问题

78 5

并行度调优疑问

29 9

yum install -y ntpdate执行报错

21 22

查看更多本课问答

请稍等 ...

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

扫描二维码
关注慕课网微信公众号