c++ - 在 CDH4 中获取 mapreduce.task.partition

Question

使用 CDH4/hadoop-2.0.0 我遇到了一个问题，其中管道程序在尝试获取任务的分区时出错：

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

这适用于 0.21，我想知道如何使用 2.0.0 实现相同的结果。任何帮助将非常感激。

PS：我试着玩弄hadoop 管道来尝试调试它。但在那里也撞到了一堵墙。叹息。

Answer 1

除了附带YARN之外，CDH4 还包括使用密钥mapred.task.partition而不是mapreduce.task.partition（从 0.21 开始）的 hadoop-0.20。将其改回前者解决了我的问题。