时间戳

首页 > 解决方案 > Oozie 作业失败 Mapr 6.x

java - Oozie 作业失败 Mapr 6.x

问题描述

我正在尝试以纱线客户端模式向 oozie 提交火花作业。当我在 oozie 之外运行 spark 作业时，它运行良好。但是当我提交 oozie 作业时，它一直失败并出现以下错误：

Exception in thread "main" java.lang.IllegalStateException: basedir job.jar/lib does not exist.
    at org.apache.tools.ant.DirectoryScanner.scan(DirectoryScanner.java:871)
    at org.apache.spark.classpath.ClasspathFilter$$anonfun$resolveClasspath$1.apply(ClasspathFilter.scala:47)
    at org.apache.spark.classpath.ClasspathFilter$$anonfun$resolveClasspath$1.apply(ClasspathFilter.scala:44)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
    at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
    at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
    at scala.collection.mutable.ArrayOps$ofRef.flatMap(ArrayOps.scala:186)
    at org.apache.spark.classpath.ClasspathFilter$.resolveClasspath(ClasspathFilter.scala:44)
    at org.apache.spark.classpath.ClasspathFilter$.main(ClasspathFilter.scala:31)
    at org.apache.spark.classpath.ClasspathFilter.main(ClasspathFilter.scala)
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/fs/FSDataInputStream
    at org.apache.spark.deploy.SparkSubmitArguments.handleUnknown(SparkSubmitArguments.scala:465)
    at org.apache.spark.launcher.SparkSubmitOptionParser.parse(SparkSubmitOptionParser.java:178)
    at org.apache.spark.deploy.SparkSubmitArguments.<init>(SparkSubmitArguments.scala:104)
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:112)
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.fs.FSDataInputStream
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 5 more
Failing Oozie Launcher, Main class [org.apache.oozie.action.hadoop.ShellMain], exit code [1]

起初，我以为它无法加载 hdfs 相关的依赖项。因此，我在类路径中添加了 hadoop 依赖项并提交了作业。但它没有用。

后来，我为我的应用程序创建了一个 uber jar 并尝试运行。结果还是一样。

如果我在 mapr 5.x 环境中运行相同的作业，情况看起来不错，并且 oozie 作业可以成功运行而没有任何问题。但同样的工作在 Mapr 6.x 环境中失败了

有没有人遇到过同样的问题？任何帮助表示赞赏。

以下是一些重要的细节：

Mapr version : 6.0.1
Spark version: 2.2.1
Oozie version: 4.3.0
Hadoop version: 2.7.0

标签： javaapache-sparkhadoopoozie

解决方案

我终于能够解决这个问题。

问题在于mapr-spark.env.sh

这里的值MAPR_HADOOP_CLASSPATH设置为`/opt/mapr/spark/spark-2.2.1/bin/mapr-classpath.sh`

我将值更改为 MAPR_HADOOP_CLASSPATH=`hadoop 类路径`。这能够正确加载 hadoop 库（尤其是 hdfs）并且 oozie 作业成功运行。

推荐阅读