Oozie 工作流应仅在有可用的输入 HDFS 文件时运行



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

Wrokflow 用于按需运行作业。您正在寻找的功能在工作流中不可用。该功能由协调员提供。

最新更新