print()算子和foreachRDD()算子的區別

使用print()算子打印結果時fastjson框架會報錯 而使用foreachRDD就不會報錯了 爲什麼,哪位大佬能夠解釋一下????????????????? 之後使用collect報了同樣的錯誤。 估計sparkstreaming中的print()算子會把excutor中的結果收集到Driver端再打印,但是JSONObject不能夠序列化,因此報錯
相關文章
相關標籤/搜索