一.原因分析
根據是使用java集合還是scala數據集原因也不盡相同。
1.java集合
因為 Java 集合類型在 Scala 操作時沒有 foreach 方法。
2.scala數據集
一般為scala版本與spark版本不兼容導致!
二.解決方案
1.java集合
需要將其轉換為Scala的集合類型, 因此需要在代碼中加入如下內容(Scala支持與Java的隱式轉換):
import scala.collection.JavaConversions._
2.scala數據集
調整scala版本。spark1.x一般使用scala2.10.x,spark2.x一般使用scala2.11.x。
