hadoop - 子工作流失败时如何中止oozie工作流？

Question

我在主工作流中创建了子工作流，它们按顺序调用，这意味着当一个完成时，下一个子工作流将被触发，但在子工作流失败时，我的主工作流没有得到中止并触发下一个子工作流程。下面给出了主要工作流程示例

<?xml version="1.0"?>
<workflow-app xmlns="uri:oozie:workflow:0.4" name="Mainworkflow_">
  <start to="subworkflow-node-abc"/>
  <action name="subworkflow-node-abc">
    <sub-workflow>
      <app-path>hdfs://link/abc.xml</app-path>
      <configuration>
        <property>
          <name>autoReconnect</name>
          <value>true</value>
        </property>
        <property>
          <name>TableName</name>
          <value>abc</value>
        </property>
        <property>
          <name>targetDirPath</name>
          <value>${targetDirPath}</value>
        </property>
      </configuration>
    </sub-workflow>
    <ok to="subworkflow-node-def"/>
    <error to="kill"/>
  </action>
  <action name="subworkflow-node-def">
    <sub-workflow>
      <app-path>hdfs://def.xml</app-path>
      <configuration>
        <property>
          <name>autoReconnect</name>
          <value>true</value>
        </property>
        <property>
          <name>TableName</name>
          <value>def</value>
        </property>
        <property>
          <name>targetDirPath</name>
          <value>${targetDirPath}</value>
        </property>
      </configuration>
    </sub-workflow>
    <ok to="end"/>
    <error to="kill"/>
  </action>
  <kill name="kill">
    <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
  </kill>
  <end name="end"/>
</workflow-app>

所以在上面的例子中，第二个工作流程被触发。任何人都可以告诉如何终止该主要工作流以防它中止。

Answer 1

你可以使用Decision Control Node

例如，如果 suv-workflow 的输出不存在 - 发送到结束/失败。