登录    关于
马育民老师的博客

马育民的博客

QQ:65242847

oozie4.1.x 执行shell脚本-执行多个任务

上接:https://www.malaoshi.top/show_1IX2FgcaJoO9.html

重写 workflow.xml

内容如下:

<workflow-app xmlns="uri:oozie:workflow:0.4" name="shell-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>${EXEC}</exec>
            <file>${shellpath}</file>
            <capture-output/>
        </shell>
        <!-- 执行成功,继续执行shell2 -->
        <ok to="shell2"/>
        <error to="fail"/>
    </action>

    <action name="shell2">
        <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>${EXEC}</exec>
            <file>${shellpath}</file>
            <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>

在 oozie web查看

访问 http://hadoop3:11000

在 yarn 查看结果

访问:http://hadoop2:8088/

可知:这2个任务在不同服务器执行

在服务器查看生成的文件

根据上图的提示,到 相应服务器 的 /program 目录下查找 oozie_hello.txt 文件,如果有该文件,说明任务成功


原文出处:http://malaoshi.top/show_1IX2IS0dQ8tN.html