Что происходит, чтобы уменьшить количество работников, которые считывали данные с работника карты, который сейчас не работает - PullRequest
0 голосов
/ 23 мая 2019

Я читал, что фаза сокращения состоит из трех задач - перемешать, отсортировать и уменьшить. Перестановка может происходить параллельно с задачами на карте. Что произойдет, чтобы уменьшить количество заданий, чья перетасовка уже началась, и одна задача карты умирает. Если задача карты завершится неудачно, она будет выполнена повторно. Как задачи будут знать, какие данные следует прочитать из новой задачи карты, поскольку они уже прочитали бы некоторые данные из старой.

...