Как установить тайм-аут задачи карты?

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() вместо.