HazelcastのMapReduceのエグゼキュータの過負荷

Question

私は新しいクラスタを設定していると私はhazelcastのMapReduceのエグゼキュータからエラーを取得しています：春を使用して

java.util.concurrent.RejectedExecutionException: Executor[mapreduce::hz::default] is overloaded

次のように、私はjobtrackerを設定しています： <hz:jobtracker name="default" max-thread-size="8" queue-size="0"/>

ドキュメントごとに、0はバインドされていないデフォルトのキューサイズです。

思考？私は約100の仕事を同時に送るだけです

Answer 1

マニュアルは間違っています。 0より小さい値は、キューサイズがpartitionCountの2倍であることを意味します。

int queueSize = jobTrackerConfig.getQueueSize(); if (queueSize <= 0) { queueSize = ps.getPartitionCount() * 2; } Code snippet on github

あなたのユースケースのために十分な大きさだ整数を使用してください。