マップタスクのタイムアウトを設定するには?

mapreduce timeout
マップタスクのタイムアウトを設定するには?

私はこれを試しました

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

しかし、私はそれが機能していないと思います。 mapred.task.timeoutを1000に設定しようとしています。マップクラスでは、「Thread.sleep(2000);」を指定し、例外がスローされることを期待しています。 しかし、それはうまく動作しています。 これは例外をスローすべきではありませんか?

  2  1


ベストアンサー

それは古い、非推奨の設定です。 新しい同等の `mapreduce.task.timeout`が必要な場合があります。 また、代わりに `Configuration.setInt()`を呼び出します。

4


タイトルとURLをコピーしました