print()算子和foreachRDD()算子的区别
使用print()算子打印结果时fastjson框架会报错
而使用foreachRDD就不会报错了 为什么,哪位大佬能够解释一下?????????????????
之后使用collect报了同样的错误。
估计sparkstreaming中的print()算子会把excutor中的结果收集到Driver端再打印,但是JSONObject不能够序列化,因此报错
使用print()算子打印结果时fastjson框架会报错
而使用foreachRDD就不会报错了 为什么,哪位大佬能够解释一下?????????????????
之后使用collect报了同样的错误。
估计sparkstreaming中的print()算子会把excutor中的结果收集到Driver端再打印,但是JSONObject不能够序列化,因此报错