Oozie并行任务异常处理需求：单分支失败时保留其余分支执行至Join节点后终止

这个需求很常见，要实现「单分支失败仅终止自身、其余分支正常执行到Join节点后再统一处理错误」的逻辑，你需要结合Oozie的错误捕获、全局变量标记和决策节点来配置，具体方案如下：

1. 给每个并行分支添加独立的错误处理与状态标记 #

绝对不能在分支内直接使用<kill>节点（否则会终止整个工作流），而是通过全局变量标记分支状态，失败时跳过后续任务直接跳转至Join节点；成功则标记状态后再进入Join。

以下是单个分支的完整示例（另外两个分支逻辑完全一致，仅名称和变量名替换即可）：

<!-- 分支1的起始任务 -->
<action name="START_PARALLEL_PATH_1">
    <shell>
        <exec>task_a1.sh</exec>
        <file>/path/to/task_a1.sh</file>
        <!-- 可添加参数、环境变量等其他配置 -->
    </shell>
    <ok to="TASK_A2"/>
    <!-- 任务失败时直接跳转到标记失败的节点 -->
    <error to="MARK_BRANCH1_FAILED"/>
</action>

<!-- 分支1的后续任务 -->
<action name="TASK_A2">
    <shell>
        <exec>task_a2.sh</exec>
        <file>/path/to/task_a2.sh</file>
    </shell>
    <ok to="TASK_A3"/>
    <error to="MARK_BRANCH1_FAILED"/>
</action>

<action name="TASK_A3">
    <shell>
        <exec>task_a3.sh</exec>
        <file>/path/to/task_a3.sh</file>
    </shell>
    <!-- 任务全部成功时，标记分支状态为成功后进入Join -->
    <ok to="MARK_BRANCH1_SUCCESS"/>
    <error to="MARK_BRANCH1_FAILED"/>
</action>

<!-- 标记分支1为失败：用Oozie自带的SetVar动作设置全局变量 -->
<action name="MARK_BRANCH1_FAILED">
    <java>
        <main-class>org.apache.oozie.action.wf.SetVar</main-class>
        <arg>name=branch1_status</arg>
        <arg>value=FAILED</arg>
        <arg>message=Branch 1 failed, marking status</arg>
    </java>
    <!-- 无论设置变量是否成功，都强制跳转至Join节点 -->
    <ok to="PARALLEL_JOIN"/>
    <error to="PARALLEL_JOIN"/>
</action>

<!-- 标记分支1为成功 -->
<action name="MARK_BRANCH1_SUCCESS">
    <java>
        <main-class>org.apache.oozie.action.wf.SetVar</main-class>
        <arg>name=branch1_status</arg>
        <arg>value=SUCCESS</arg>
    </java>
    <ok to="PARALLEL_JOIN"/>
    <error to="PARALLEL_JOIN"/>
</action>

对另外两个分支（START_PARALLEL_PATH_2、START_PARALLEL_PATH_3）重复上述逻辑，分别设置branch2_status和branch3_status变量即可。

2. 配置Join节点等待所有分支完成 #

保持你的<join>节点逻辑，确保所有分支（无论成功或失败处理后）最终都指向该节点：

<join name="PARALLEL_JOIN" to="CHECK_BRANCH_STATUS"/>

3. 添加决策节点统一检查分支状态 #

在Join节点之后，用<decision>节点判断所有分支的状态：如果任意分支标记为FAILED，则触发全局终止；否则继续执行后续任务：

<decision name="CHECK_BRANCH_STATUS">
    <switch>
        <!-- 检查是否有分支失败 -->
        <case to="GLOBAL_KILL">
            ${branch1_status == 'FAILED' || branch2_status == 'FAILED' || branch3_status == 'FAILED'}
        </case>
        <!-- 所有分支成功，继续后续流程 -->
        <default to="NEXT_TASK_AFTER_JOIN"/>
    </switch>
</decision>

<!-- 全局终止节点：输出错误信息并结束工作流 -->
<kill name="GLOBAL_KILL">
    <message>Workflow terminated due to failed branch. Statuses: [${branch1_status}, ${branch2_status}, ${branch3_status}]</message>
</kill>

<!-- 所有分支成功后的后续任务示例 -->
<action name="NEXT_TASK_AFTER_JOIN">
    <shell>
        <exec>post_join_task.sh</exec>
        <file>/path/to/post_join_task.sh</file>
    </shell>
    <ok to="END"/>
    <error to="GLOBAL_KILL"/>
</action>

<end name="END"/>

关键注意事项 #

• 变量作用域：Oozie的工作流变量是全局的，分支内设置的branchX_status可以在Join后的决策节点正常访问。
• 错误覆盖：确保分支内所有任务都配置了<error>跳转，避免遗漏未处理的错误导致全局终止。
• 容错处理：即使SetVar节点执行失败（极端情况），也通过<error to="PARALLEL_JOIN"/>确保分支能到达Join节点，避免工作流挂起。

这样配置后，当某条分支任务失败时，该分支会跳过后续任务、标记状态后进入Join；其余分支不受影响继续执行；最后由决策节点统一判断是否终止整个工作流，完全符合你的预期逻辑。

内容的提问来源于stack exchange，提问作者user1485864