Exception in thread “main” java.lang.NoClassDefFoundError: scala/Product$class
object SparkWorldCountApp {
def main(args: Array[String]):Unit={
val sparkConf=new SparkConf().setMaster(“local”) 这一行出错
val sc=new SparkContext(sparkConf);
val rdd=sc.textFile(“file:E:\workspace\sparkSqlTrain\data\input.txt”)
rdd.collect().foreach(println)
sc.stop()
}
}
pom文件
<scala.version>2.12.13</scala.version>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
UTF-8
<scala.tools.version>2.12</scala.tools.version>
<spark.version>2.4.3</spark.version>
<hadoop.version>2.6.0-cdh5.15.1</hadoop.version>