如果有可用的输入 hdfs 文件,oozie 工作流应该只 运行
oozie workflow should only run if there is an input hdfs file available
我设置了协调器 <dataset>
和 <input-events>
值和超时。
协调器工作正常,因为它会检查输入文件是否在 hdfs 位置可用,然后才 运行 工作流超时。
我在工作流中需要相同的行为,如果我 运行 只是一个没有协调器的工作流,那么工作流的行为应该与上述协调器的行为相同。
我尝试 mapred.input.dir
但工作流程 运行 成功。
有没有其他方法可以达到同样的效果。
工作流是一个简单的 hello world 作业,而不是 map-reduce 作业。
工作流程适用于 运行 个作业 on-demand。 您正在寻找的功能在 Workflow 中不可用。该功能由协调器提供。
我设置了协调器 <dataset>
和 <input-events>
值和超时。
协调器工作正常,因为它会检查输入文件是否在 hdfs 位置可用,然后才 运行 工作流超时。
我在工作流中需要相同的行为,如果我 运行 只是一个没有协调器的工作流,那么工作流的行为应该与上述协调器的行为相同。
我尝试 mapred.input.dir
但工作流程 运行 成功。
有没有其他方法可以达到同样的效果。
工作流是一个简单的 hello world 作业,而不是 map-reduce 作业。
工作流程适用于 运行 个作业 on-demand。 您正在寻找的功能在 Workflow 中不可用。该功能由协调器提供。