Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <workflow-app xmlns="uri:oozie:workflow:0.4" name="spark-submit-wf">
- <start to="shell-node"/>
- <action name="shell-node">
- <shell xmlns="uri:oozie:shell-action:0.2">
- <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-submit</exec>
- <argument>--master</argument>
- <argument>yarn-client</argument>
- <argument>--class</argument>
- <argument>prod.JavaHelloWorld</argument>
- <argument>/home/ubuntu/test-oozie-mq/spark.app.jar</argument>
- <capture-output/>
- </shell>
- <ok to="end"/>
- <error to="fail"/>
- </action>
- <kill name="fail">
- <message>Shell action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
- </kill>
- <end name="end"/>
- </workflow-app>
Advertisement
Add Comment
Please, Sign In to add comment