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算子

接口抽象内部类

从后台只有用Map才能传到前台去吗？

关于内部类被 static 修饰

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

大数据工程师 2024 版

参与学习 1151 人
提交作业 5960 份
解答问题 1144 个

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

本课精华内容

问答作业

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

54 2

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

31 1

数据倾斜问题

78 5

并行度调优疑问

29 9

yum install -y ntpdate执行报错

17 20

查看更多本课问答

请稍等 ...

意见反馈帮助中心 APP下载