0

を使用して、次のようstreamingに の数を に設定しmapます200。

-D mapred.map.tasks=200 -D mapred.job.map.capacity=200

しかし後で、実行中のマッパーの数が9で、500 以上のマッパー タスクが保留中であることがわかりました。これは私にはかなり奇妙に見えますが、実行する必要があると思います200よね? なぜ9回だけ走るのですか？

4

1 に答える 1