Hadoop MapReduce では、すべてのマッパーが終了するまでリデューサーは開始されません。このロジックが実装されている部分/クラス/コードラインを誰か説明してもらえますか? Hadoop MapReduce バージョン 1 (Yarn ではありません) について話しています。map reduce フレームワークを検索しましたが、非常に多くのクラスがあり、メソッド呼び出しとその順序がよくわかりません。
言い換えれば、マッパーがまだ機能している場合でも、レデューサーが削減を開始できるようにする必要があります (最初にテスト目的で)。このようにして、仕事に対して誤った結果が得られることは知っていますが、これがフレームワークの一部を変更するための作業の始まりであることを知っています。では、どこから見て変更を加える必要がありますか?