如何设置地图任务超时时间？

Question

我试过这个

Configuration conf = new Configuration();
conf.set("mapred.task.timeout", "1000");
Job job = new Job(conf);

但我认为这是行不通的。我试图将 mapred.task.timeout 设置为 1000 并且在地图类中我给出了一个“ Thread.sleep(2000); ”并期望它抛出异常。但它运行良好。这不应该抛出异常吗？

Answer 1

这是一个旧的，不推荐使用的配置设置。您可能需要更新的等效项mapreduce.task.timeout. 另外，请Configuration.setInt()改为调用。