scala:spark版本導致的錯誤

筆者用的是1.6的老版本spark,在本地環境用的是2.11.8來完成代碼編譯,但是提交到集羣跑的時候,報了上圖的錯。 查了一下,1.6的spark默認是用2.10的scala來編譯的,而我本地用的是2.11,所以就出現瞭如上錯誤。 解決也很簡單,將本地的scala環境換成scala2.10的就完事了。
相關文章
相關標籤/搜索