Yarn, Sparkle

Question

üzerinde Spark scala işi nasıl gönderilir Spark için yeni ve sahte bir dağıtılmış Hadoop sisteminde bir scala işi çalıştırmaya çalışıyorum.

Hadoop 2.6 + İplik + Kıvılcım 1.6.1 + scala 2.10.6 + JVM 8, her şey sıfırdan kurulmuş.

Scala uygulamam basit bir WordCount örneğidir, hatanın ne olduğuna dair bir ipucum yok.

/usr/local/sparkapps/WordCount/src/main/scala/com/mydomain/spark/wordcount/WordCount.scala 

package com.mydomain.spark.wordcount 
import org.apache.spark.{SparkConf, SparkContext} 
import org.apache.spark.SparkContext._ 

object ScalaWordCount { 
    def main(args: Array[String]) { 
     val logFile = "/home/hduser/inputfile.txt" 
     val sparkConf = new SparkConf().setAppName("Spark Word Count") 
     val sc = new SparkContext(sparkConf) 
     val file = sc.textFile(logFile) 
     val counts = file.flatMap(_.split(" ")).map(word => (word, 1)).reduceByKey(_ + _) 
     counts.saveAsTextFile("/home/hduser/output") 
    } 
} 

sbt dosyası:

/usr/local/sparkapps/WordCount/WordCount.sbt 


name := "ScalaWordCount" 

version := "1.0" 

scalaVersion := "2.10.6" 

libraryDependencies += "org.apache.spark" %% "spark-core" % "1.6.1" 

Derleme:

$ cd /usr/local/sparkapps/WordCount/ 
$ sbt package 

Gönder:

spark-submit --class com.mydomain.spark.wordcount.ScalaWordCount --master yarn-cluster /usr/local/sparkapps/WordCount/target/scala-2.10/scalawordcount_2.10-1.0.jar 

Çıktı:

Exception in thread "main" org.apache.spark.SparkException: Application application_1460107053907_0003 finished with failed status 
at org.apache.spark.deploy.yarn.Client.run(Client.scala:1034) 
at org.apache.spark.deploy.yarn.Client$.main(Client.scala:1081) 
at org.apache.spark.deploy.yarn.Client.main(Client.scala) 
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
at java.lang.reflect.Method.invoke(Method.java:497) 
at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:731) 
at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:181) 
at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:206) 
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:121) 
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) 

Kıvılcım Günlük Dosyası: HDF'ler: Yerel dosyayı okumak istiyorsanız günlükleri :: itibaren http://pastebin.com/FnxFXimM

Answer 1

16/04/08 12:24:41 ERROR ApplicationMaster: User class threw exception: org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: hdfs://localhost:9000/home/hduser/inputfile.txt 

,

val logFile = "file:///home/hduser/inputfile.txt"