2017-01-08 2 views
0

Exception in thread "main" java.lang.NoClassDefFoundError: scala/Product$class at org.apache.spark.SparkConf$DeprecatedConfig.(SparkConf.scala:762) at org.apache.spark.SparkConf$.(SparkConf.scala:615) at org.apache.spark.SparkConf$.(SparkConf.scala) at org.apache.spark.SparkConf.set(SparkConf.scala:84) at org.apache.spark.SparkConf.set(SparkConf.scala:73) at org.apache.spark.SparkConf.setMaster(SparkConf.scala:105)スパーク語のIntelliJでカウントエラーによるためのScala 2.12.1

package bigdata.spark_applications 
import org.apache.spark.SparkConf 
import org.apache.spark.SparkContext 
import org.apache.spark.SparkContext._ 
object WordCount { 
    def main(args: Array[String]): Unit = { 
    val conf = new SparkConf().setMaster("local").setAppName("WordCount") 
    val sc = new SparkContext(conf) 
    val data = sc.textFile("C:\\Users\\scala.txt") 
    val result = data.flatMap(_.split(" ")).map(word => (word , 1)).reduceByKey(_ + _) 
    result.collect.foreach(println) 
    } 

答えて

2

こんにちは私はスカラ座2.12.1と火花コアを使用していた、

を答えを得たが2.12.1には使用できませんそうプロジェクトで、私は依存して2.11に

バージョンをスカラ2.11.8および変更火花コアを使用した:= "1.0"

scalaVersion:= "2.11.8"

libraryDependencies + = "org.apache.spark"% "spark-core_2.11"% "2.1.0" libraryDependencies + = "org.apache.spark"% "spark-sql_2.11"% "2.1.0 "

+0

この回答をお寄せいただきありがとうございます。私は同じ問題を抱えていた。 – PanwarS87

関連する問題