在你的job的RecordReader和Mapper等关键步骤中打出log,看看有没有在执行。如果没有执行日志,建议检查job中自定义的部分,看是否是代码逻辑问题,最好贴出代码。如果有在执行,而且最终能完成,但map进度不正常,问题则是你自定义的RecordReader中的getProgress()方法没有正确计算进度。
在你的job的
RecordReader
和Mapper
等关键步骤中打出log,看看有没有在执行。如果没有执行日志,建议检查job中自定义的部分,看是否是代码逻辑问题,最好贴出代码。如果有在执行,而且最终能完成,但map进度不正常,问题则是你自定义的RecordReader
中的getProgress()
方法没有正确计算进度。