2017-05-15 17 views
1

私はsparkシェルで私のsparkアプリケーションを実行しようとしています。ここで私が試したことと、このエラーで何時間も読んだ後の多くの亜種があります...しかし、どれもうまくいかないようです。代わりに取得された何spark-shell、依存関係jar、クラスが見つかりません例外

spark-shell --class my_home.myhome.RecommendMatch —jars /Users/anon/Documents/Works/sparkworkspace/myhome/target/myhome-0.0.1-SNAPSHOT.jar,/Users/anon/Documents/Works/sparkworkspace/myhome/target/original-myhome-0.0.1-SNAPSHOT.jar 

java.lang.ClassNotFoundException: my_home.myhome.RecommendMatch 
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) 
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
at java.lang.Class.forName0(Native Method) 
at java.lang.Class.forName(Class.java:348) 
at org.apache.spark.util.Utils$.classForName(Utils.scala:229) 
at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:695) 
at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:187) 
at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:212) 
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:126) 
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) 

任意のアイデアしてくださいますか?ありがとう!

UPDATE: が見つかりましたいくつかの記事/ドキュメントに

spark-shell --class my_home.myhome.RecommendMatch —jars /Users/anon/Documents/Works/sparkworkspace/myhome/target/myhome-0.0.1-SNAPSHOT.jar:/Users/anon/Documents/Works/sparkworkspace/myhome/target/original-myhome-0.0.1-SNAPSHOT.jar 

を説明するようにjarがコロン(:)で区切らなくカンマ(、)分離されなければならないということが、今でエラーが変更されました。注ls -laはパスを検出しますが、次の行は終了しないと文句を言います。奇妙な..

Warning: Local jar /Users/anon/Documents/Works/sparkworkspace/myhome/target/myhome-0.0.1-SNAPSHOT.jar:/Users/anon/Documents/Works/sparkworkspace/myhome/target/original-myhome-0.0.1-SNAPSHOT.jar does not exist, skipping. 
Setting default log level to "WARN". 
To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel). 
java.lang.SecurityException: Invalid signature file digest for Manifest main attributes 
at sun.security.util.SignatureFileVerifier.processImpl(SignatureFileVerifier.java:314) 
at sun.security.util.SignatureFileVerifier.process(SignatureFileVerifier.java:268) 

UPDATE 2:

spark-shell —class my_home.myhome.RecommendMatch —-jars “/Users/anon/Documents/Works/sparkworkspace/myhome/target/myhome-0.0.1-SNAPSHOT.jar:/Users/anon/Documents/Works/sparkworkspace/myhome/target/original-myhome-0.0.1-SNAPSHOT.jar” 

上記のコマンドは、火花シェルで次のように得られます。

Setting default log level to "WARN". 
To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel). 
17/05/16 01:19:08 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 
17/05/16 01:19:13 WARN ObjectStore: Failed to get database global_temp, returning NoSuchObjectException 
Spark context Web UI available at http://192.168.0.101:4040 
Spark context available as 'sc' (master = local[*], app id = local-1494877749685). 
Spark session available as 'spark'. 
Welcome to 
     ____    __ 
    /__/__ ___ _____/ /__ 
    _\ \/ _ \/ _ `/ __/ '_/ 
    /___/ .__/\_,_/_/ /_/\_\ version 2.1.0 
     /_/ 

Using Scala version 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_121) 
Type in expressions to have them evaluated. 
Type :help for more information. 

scala> :load my_home.myhome.RecommendMatch 
That file does not exist 

scala> :load RecommendMatch 
That file does not exist 

scala> :load my_home.myhome.RecommendMatch.scala 
That file does not exist 

scala> :load RecommendMatch.scala 
That file does not exist 

瓶がロードされていないようです:(私が見たものに基づいてhttp://localhost:4040/environment/

答えて

0

--jarsに供給されたURLは、カンマで区切る必要があります。あなたの最初のコマンドは正しいです。

また、提出火花最後のparamにjarファイルを追加する必要があり

my_home.myhome.RecommendMatchMYHOME-0.0.1-SNAPSHOT.jarに jarファイルの一部であると言うことができます。

spark-submit --class my_home.myhome.RecommendMatch \ 
—jars "/Users/anon/Documents/Works/sparkworkspace/myhome/target/original-myhome-0.0.1-SNAPSHOT.jar" \ 
/Users/anon/Documents/Works/sparkworkspace/myhome/target/myhome-0.0.1-SNAPSHOT.jar 
関連する問題