oozie - 当其中一个分叉操作成功时 Oozie 加入

Question

我有一个 oozie 工作流程，它从具有两个动作 watcher1 和 watcher2 的分叉开始。一旦其中一个，即 watcher1 或 watcher2 成功，我需要继续加入。

我可以在 oozie 中做些什么来实现上述场景。

Answer 1

您可以在join中使用条件语句，在watcher进程完成后，为两个进程生成一个虚拟文件并检查该文件是否已经存在，如果存在则直接将此进程发送到join节点，如果不存在则调度根据要求采取行动。将此逻辑应用于两个观察者。您的加入节点应该是此过程中的最后一个节点。