Oozie 作业失败 Mapr 6.x

Question

我正尝试在 yarn-client 模式下向 oozie 提交一个 spark 作业。当我运行 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.apply(ClasspathFilter.scala:47)
    at org.apache.spark.classpath.ClasspathFilter$$anonfun$resolveClasspath.apply(ClasspathFilter.scala:44)
    at scala.collection.TraversableLike$$anonfun$flatMap.apply(TraversableLike.scala:241)
    at scala.collection.TraversableLike$$anonfun$flatMap.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 env

上失败了

有人遇到过同样的问题吗？感谢任何帮助。

这里有一些重要的细节：

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

Answer 1

我终于解决了这个问题。

问题出在 mapr-spark.env.sh

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

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

Oozie 作业失败 Mapr 6.x

Oozie jobs failing Mapr 6.x

java

apache-spark

hadoop

oozie