主要原因就是hadoop1.x的FileInputFormat.setInputPaths(job, new Path(input));

在hadoop2.x的环境运行导致的,将上述代码用下面两行代码替换即可:

 FileInputFormat.setInputDirRecursive(job, true);
 FileInputFormat.addInputPath(job, new Path(input));

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐