В настоящее время я пытаюсь протестировать поток локально, который включает в себя отправку работы в Had oop (в данном случае с использованием LocalJobRunner
), получение JobID
из этой отправленной работы и затем использование JobClient
проверить статус работы. Однако кажется, что JobClient
всегда возвращает null
для любого идентификатора задания, который я проверяю. И JobClient
, и само задание инициализируются с mapred.job.tracker = local
.
Работает ли JobClient
на самом деле при использовании с LocalJobRunner
, или они несовместимы?