timeout - 如何设置 map task 超时时间？

Question

我试过了

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

但我认为它不起作用。我正在尝试将 mapred.task.timeout 设置为 1000，并且在 map 类中我给出了“Thread.sleep(2000);”并期望它抛出异常。但它运行良好。这不应该抛出异常吗？

Answer 1

这是一个旧的、已弃用的配置设置。您可能需要更新的等效项 mapreduce.task.timeout。此外，改为调用 Configuration.setInt()。