0

appengineのJavamapreduceモジュールを使用しています次の情報メッセージが表示されます

マッパーの割り当てが不足しています。クォータが補充されるまでリクエストを中止します。マッパージョブをより速く完了させたい場合は、mapreduce.mapper.inputprocessingrate(デフォルトは1000)を増やすことを検討してください。

タスクパラメータ。
キュー名=デフォルト
レート=1/s
バケットサイズ=1

KINDのエンティティは約2000あり、map()呼び出しでロギングを行っています。

その情報メッセージを取り除くために提供する必要があるmapreduce/taskパラメーター。

-Aswath

4

1 に答える 1

0

これは、フレームワーク自体によって実装された mapreduce の特別なクォータだと思います。リソースを消費できる速度を制限するように設計されているため、mapreduce は利用可能なアプリ エンジンのクォータをすぐに使い切ってしまうことはありません。1 秒あたりの map() 呼び出しの最大全体レートを示しているようです。

mapreduce.mapper.inputprocessingrateマップ ジョブの構成でプロパティを増やしてみてください。または、テストのために、で定義されているデフォルトを変更できますmapreduce/AppEngineJobContext.java

public static final int DEFAULT_MAP_INPUT_PROCESSING_RATE = 1000;
于 2012-05-09T05:50:56.270 に答える