糸クラスターのdeeplearning4jが失敗する

Question

私は、master = yarn-clusterを使用してクラスター上にjarファイルを提出したいがエラーが発生する。

java.lang.NoClassDefFoundError: org/nd4j/Nd4jRegistrator 
     at Main.main(Main.java:51) 
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
     at java.lang.reflect.Method.invoke(Method.java:606) 
     at org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:552) 
Caused by: java.lang.ClassNotFoundException: org.nd4j.Nd4jRegistrator 
     at java.net.URLClassLoader$1.run(URLClassLoader.java:366) 
     at java.net.URLClassLoader$1.run(URLClassLoader.java:355) 
     at java.security.AccessController.doPrivileged(Native Method) 
     at java.net.URLClassLoader.findClass(URLClassLoader.java:354) 
     at java.lang.ClassLoader.loadClass(ClassLoader.java:425) 
     at java.lang.ClassLoader.loadClass(ClassLoader.java:358) 

私は、クリオ語シリアライザを使用して、このようsparkConfを設定し、私は例外を持っていたので、私はそれなしでポンポンファイル内

SparkConf sparkConf = new SparkConf().setMaster(master).setAppName("DL4J Spark Example"); 
sparkConf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer"); 
sparkConf.set("spark.kryo.registrator", "org.nd4j.Nd4jRegistrator"); 
JavaSparkContext sc = new JavaSparkContext(sparkConf); 

依存関係を実行すると：

<dependencies> 
     <dependency> 
      <groupId>org.apache.spark</groupId> 
      <artifactId>spark-core_2.10</artifactId> 
      <version>1.6.0</version> 
     </dependency> 

     <dependency> 
      <groupId>org.deeplearning4j</groupId> 
      <artifactId>deeplearning4j-core</artifactId> 
      <version>0.8.0</version> 
     </dependency> 

     <dependency> 
      <groupId>org.deeplearning4j</groupId> 
      <artifactId>dl4j-spark_2.10</artifactId> 
      <version>0.8.0_spark_1</version> 
     </dependency> 

     <dependency> 
      <groupId>org.nd4j</groupId> 
      <artifactId>nd4j-native-platform</artifactId> 
      <version>0.8.0</version> 
     </dependency> 

     <dependency> 
      <groupId>org.nd4j</groupId> 
      <artifactId>nd4j-kryo_2.10</artifactId> 
      <version>0.8.0</version> 
     </dependency> 

     <dependency> 
      <groupId>com.esotericsoftware</groupId> 
      <artifactId>kryo</artifactId> 
      <version>4.0.0</version> 
     </dependency> 
    </dependencies> 

をそれが見つけることができませんNd4jRegistratorクラスですが、なぜですか？ 私はローカルを実行するとき、これは正しく動作します。

Answer 1

uberjarを正しくセットアップしなかったと思いますか？すべてを束ねる必要があります。あなたのポンは全体的に大丈夫です。