を使用して、次のようstreamingに の数を に設定しmapます200。
-D mapred.map.tasks=200 -D mapred.job.map.capacity=200
しかし後で、実行中のマッパーの数が9で、500 以上のマッパー タスクが保留中であることがわかりました。これは私にはかなり奇妙に見えますが、実行する必要があると思います200よね? なぜ9回だけ走るのですか？
質問する
122 次
を使用して、次のようstreamingに の数を に設定しmapます200。
-D mapred.map.tasks=200 -D mapred.job.map.capacity=200
しかし後で、実行中のマッパーの数が9で、500 以上のマッパー タスクが保留中であることがわかりました。これは私にはかなり奇妙に見えますが、実行する必要があると思います200よね? なぜ9回だけ走るのですか？