job

-submit <job-file>

Запускает задачу

-status <job-id>

Выводит прогресс map/reduce-задач и все счетчики задач

-counter <job-id> | <group-name> | <counter-name>

Выводит значение счетчика

-kill <job-id>

Завершает задачу

-events <job-id> | <from-event-#> | <#-of-events>

Выводит подробную информацию о событиях, полученных от jobtracker в заданном интервале

-history [all] jobHistoryFilejobId [-outfile <file>] [-format human|json]

Выводит сведения о задачах, сведения о неудачных и завершенных задачах. Флаг all выводит дополнительные сведения о задачах, такие как количество успешных задач, попытки выполнения каждой задачи, счетчики задач и так далее. -outfile <file> позволяет направить вывод в файл (вместо stdout). Формат по умолчанию удобочитаемый, но его также можно изменить на JSON с помощью флага -format

-list [all]

Отображает незавершенные задачи. -list all отображает все задачи

-kill-task <task-id>

Завершает задачу (kill). Задачи, завершенные таким образом, НЕ считаются неудачными попытками

-fail-task <task-id>

Завершает задачу (fail). Задачи, завершенные таким образом, считаются неудачными попытками

-set-priority <job-id> <priority>

Изменяет приоритет задачи. Валидные значения: VERY_HIGH, HIGH, NORMAL, LOW, VERY_LOW

-list-active-trackers

Выводит список всех активных NodeManagers в кластере

-list-blacklisted-trackers

Выводит список трекеров задач, занесенных в черный список в кластере. Эта команда не поддерживается в кластерах на основе MRv2

list-attempt-ids <job-id> <task-type> <task-state>

Выводит ID попыток на основе предоставленного типа задачи и состояния. Допустимые типы задач: REDUCE, MAP. Допустимые состояния задачи: running, pending, completed, failed, killed

-logs <job-id> <task-attempt-id>

Создает дамп логов контейнера для задачи, если <task-attempt-id> не указан. В противном случае создает дамп логов задачи с указанным <task-attempt-id>. Логи выгружаются в стандартный вывод

-config <job-id> <file>

Загружает файл конфигурации задачи