oozie 工作流应该仅在有可用的输入 hdfs 文件时运行

Question

我设置了协调器 <dataset> 和 <input-events> 值和超时。 协调器工作正常，因为它会检查输入文件是否在 hdfs 位置可用，然后它才会运行工作流，否则会超时。 我在工作流中需要相同的行为，例如如果我只运行没有协调器的工作流，那么工作流的行为应该与上述协调器的行为相同。 我尝试了mapred.input.dir，但工作流程运行成功。 有没有其他方法可以达到同样的效果。 工作流是一个简单的 hello world 作业，而不是 map-reduce 作业。

Answer 1

Wrokflow 用于按需运行作业。 您正在寻找的功能在 Workflow 中不可用。该功能由 Coordinator 提供。