マップタスクのタイムアウトを設定するにはどうすればよいですか？

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()と電話してください。