在过去的几周里,我们每天使用 hadoop 流计算一些报告。最近我们对我们的程序做了一个改动,如果输入的大小小于10MB,我们会在JobConf中设置mapred.job.tracker=local,那么job就会在本地运行。
但是昨晚,许多作业都失败了,runningJob.getJobState() 返回了状态 3。我不知道为什么,stderr 中什么也没有。
我无法搜索与此问题相关的任何内容。所以我想知道我是否应该在生产模式下使用 mapred.job.tracker=local ?也许它只是hadoop提供的开发中的调试解决方案。
有人知道吗?任何东西,任何信息,谢谢。