如何设置地图任务超时？

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()。