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