当分叉操作之一成功时 Oozie 加入

Question

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

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

Answer 1

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