]3]
在你的job的RecordReader和Mapper等关键步骤中打出log,看看有没有在执行。如果没有执行日志,建议检查job中自定义的部分,看是否是代码逻辑问题,最好贴出代码。如果有在执行,而且最终能完成,但map进度不正常,问题则是你自定义的RecordReader中的getProgress()方法没有正确计算进度。
RecordReader
Mapper
getProgress()
可以在一些节点打些Log看看都发生了什么。不过有的时候也可能是集群卡住了,要等待一下。
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
暂无简介
文章 0 评论 0
接受
发布评论
评论(2)
在你的job的
RecordReader
和Mapper
等关键步骤中打出log,看看有没有在执行。如果没有执行日志,建议检查job中自定义的部分,看是否是代码逻辑问题,最好贴出代码。如果有在执行,而且最终能完成,但map进度不正常,问题则是你自定义的RecordReader
中的getProgress()
方法没有正确计算进度。可以在一些节点打些Log看看都发生了什么。
不过有的时候也可能是集群卡住了,要等待一下。