2 个回答

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

可以在一些节点打些Log看看都发生了什么。
不过有的时候也可能是集群卡住了,要等待一下。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进