Obtenir mapreduce.task.partition dans CDH4

Question

Avec CDH4/Hadoop 2.0.0 Je me présente dans une question dans laquelle un programme de tuyaux est erroring quand il tente d'obtenir la partition d'une tâche:

Hadoop Pipes Exception: Key mapreduce.task.partition not found in JobConf 

Cela a fonctionné juste bien avec 0,21 et je me demandais comment le même résultat peut être atteint avec 2.0.0. Toute aide serait très appréciée. PS: J'ai essayé de jouer avec hadoop pipes pour essayer de déboguer ceci. Mais a couru dans un mur là aussi. soupir.

Answer 1

Outre l'expédition avec YARN, CDH4 inclut hadoop-0.20 qui utilise la clé mapred.task.partition au lieu de mapreduce.task.partition (à partir de 0,21). Changer le retour à l'ancien a résolu mon problème.