Je planifie un travail oozie avec la structure suivante dans le cluster azur hdinsight spark2. I prévu pour le travail en utilisant les commandes suivantes en suivant ces,Code d'erreur: JA018 whie runnnig oozie flux de travail dans le cluster HD2 d'étincelles HDInsight
oozie job -config /job.properties -run
oozie job -config /coordinator.properties -run
Mais je reçois l'erreur suivante comme
Status: ERROR
Error Code: JA018
Error Message: Main class [org.apache.oozie.action.hadoop.ShellMain], exit code
Mon fichier workflow.xml:
<workflow-app name="sparkshellwf" xmlns="uri:oozie:workflow:0.3">
<start to="sparkshellwf"/>
<action name="sparkshellwf">
<shell xmlns="uri:oozie:shell-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<configuration>
<property>
<name>mapred.job.queue.name</name>
<value>${queueName}</value>
</property>
</configuration>
<exec>$SPARK_HOME/bin/spark-submit</exec>
<!--Adding all arguments needed/optional for Spark-submit here-->
<argument>--class</argument>
<argument>${Spark_Driver}</argument>
<argument>--master</argument>
<argument>${Spark_Master}</argument>
<argument>--deploy-mode</argument>
<argument>${Spark_Mode}</argument>
<argument>--num-executors</argument>
<argument>${numExecutors}</argument>
<argument>--driver-memory</argument>
<argument>${driverMemory}</argument>
<argument>--executor-memory</argument>
<argument>${executorMemory}</argument>
<argument>--executor-cores</argument>
<argument>${executorCores}</argument>
<argument>${workflowRoot}/lib/${sparkJar}</argument>
</shell>
<ok to="end"/>
<error to="fail"/>
</action>
<kill name="fail">
<message>Job failed, error message[${wf:errorMessage(wf:lastErrorNode())}] </message>
</kill>
<end name="end"/>
</workflow-app>
Mais le travail Spark fonctionne correctement, avec hout toute erreur
Je reçois la réponse oozie est comme ci-dessus.
Oozie signale que le statut final ** Fils ** n'était pas correct. Peut-être une erreur dans le nettoyage final. Regardez les journaux Yarn pour 'application _ ******* _ 0038' (quel que soit l'ID indiqué comme ID externe, mais en remplaçant le préfixe' job' hérité par 'application') –