0

現在、Hadoop の疑似分散モードで作業しています。私のreduce関数の仕組みは次のとおりです。キーごとに、その値の配列リストを作成し、シングルトンクラスのインスタンスを作成します[このクラスはライブラリに存在するため、変更できません]。次に、このインスタンスのメソッドを呼び出します。

今私の問題は次のとおりです。マップ関数が2つのキーを発行すると、レデューサーは別のキーに対して1つのキーのみを処理し、「Java.lang.exception」クラス[シングルトンのもの]をインスタンス化できないと言うでしょう。

私の懸念は、なぜこれが起こっているのですか?疑似分散モードと同様に、各レデューサーは異なる JVM を実行します!

4

0 に答える 0