java - map 变为 100% 然后下降到 0%?

标签 java hadoop mapreduce

我是 MR 的新人,但这似乎不应该发生。这是输出:

 11/12/07 13:24:42 INFO mapred.JobClient: Running job: job_201112071322_0001
 11/12/07 13:24:43 INFO mapred.JobClient:  map 0% reduce 0%
 11/12/07 13:24:57 INFO mapred.JobClient:  map 100% reduce 0%
 11/12/07 13:41:48 INFO mapred.JobClient:  map 100% reduce 16%
 11/12/07 13:42:18 INFO mapred.JobClient:  map 100% reduce 33%
 11/12/07 13:59:53 INFO mapred.JobClient:  map 100% reduce 0%
 11/12/07 14:00:04 INFO mapred.JobClient:  map 50% reduce 0%
 11/12/07 14:00:24 INFO mapred.JobClient:  map 0% reduce 0%

注意时间。它也只是坐在那里,没有完成,也没有出错。我想错误会在 reducer 中,所以我把它包括在内;如果其他代码是可疑的,我会发布它,只问。

代码:http://pastebin.com/uuL1Cgx4

非常感谢任何帮助!

最佳答案

几天前我遇到了类似的问题。达到 100% 后,我的映射器将降至 0%。

最后我发现map输出和reduce输入的数据类型定义是不同的。因此 map 和 reduce 之间的复制/洗牌/合并数据流选项将不起作用,即使 hadoop JobTracker 重试也是如此。

希望对你有用。

关于java - map 变为 100% 然后下降到 0%?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8426480/

相关文章:

java - 基于角色的 Spring Security 重定向不起作用

java - 如何在 HtmlUnit 中将 HtmlPage 转换为 Html 字符串

java - 查询 Hibernate 缓存

java - 如何隐藏特定片段中的操作栏

hadoop - 简单的插入查询到配置单元给出错误

hadoop - Kafka Connect可以成为我的Hadoop集群的一部分吗?

hadoop - Hadoop 级联的好教程

java - 如何在不缓存 hadoop 1.0.3 的情况下多次迭代 hadoop reduce 值?

hadoop - 如何修复 "Task attempt_201104251139_0295_r_000006_0 failed to report status for 600 seconds."

cuda - GPU (CUDA) 上是否有 MapReduce 实现?