如何設置地圖任務超時？

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