이 스파크 예제를 어떻게 컴파일해야합니까?

Question

나는 spark 클러스터에 익숙하지 않고 실제로 spark 웹 사이트에서 주어진 예제를 실행 중이다. 이 점에서 어떤 도움에 감사드립니다

[error] /home/subodh/Downloads/spark-0.6.1/example/src/main/scala/SimpleJob.scala:7: type mismatch; 
**[error] found : java.lang.String("target//scala-2.9.2//simple-project_2.9.2-1.0.jar") 
[error] required: Seq[String]** 
[error] val jarName:Seq[String] = "target//scala-2.9.2//simple-project_2.9.2-1.0.jar" 
[error]       ^
[error] one error found 
[error] {file:/home/subodh/Downloads/spark-0.6.1/example/}default-9e9e7d/compile:compile: Compilation failed 
[error] Total time: 3 s, completed Jan 31, 2013 11:31:21 PM 

:이 사용 SBT 패키지 명령을 컴파일 할 때, 그것은 나에게 다음과 같은 오류를 제공

/*** SimpleJob.scala ***/ 
import spark.SparkContext 
import SparkContext._ 

object SimpleJob extends Application { 
    val logFile = "//var//log//syslog" // Should be some file on your system 
    val jarName:Seq[String] = "target//scala-2.9.2//simple-project_2.9.2-1.0.jar" 
    val sc = new SparkContext("local", "Simple Job", "/home/subodh/Downloads/spark-0.6.1/bin",jarName) 
    val logData = sc.textFile(logFile, 2).cache() 
    val numAs = logData.filter(line => line.contains("a")).count() 
    val numBs = logData.filter(line => line.contains("b")).count() 
    println("Lines with a: %s, Lines with b: %s".format(numAs, numBs)) 
} 

.

Answer 1

jarName은 Seq[String] 유형으로 선언되었지만 String "target // scala-2.9.2 // simple-project_2.9.2-1.0.jar"이라고했습니다. 값을 Seq("target//scala-2.9.2//simple-project_2.9.2-1.0.jar")으로 변경하면 수정됩니다.

scala> val jarName:Seq[String] = Seq("target//scala-2.9.2//simple-project_2.9.2-1.0.jar") 
jarName: Seq[String] = List(target//scala-2.9.2//simple-project_2.9.2-1.0.jar)