这个原因是因为你自定义了outputformat或者inputformat导致你hdfs系统不能识别hdfs文件。
报错的解释是他更期待本机路径上的文件。

那么你可以在jobmian的代码上补上你hdfs的默认路径

Configuration configuration = new Configuration();
        configuration.set("fs.defaultFS", "hdfs://192.168.10.101:9000");
        //记得修改成自己hdfs的路径,前面一个不动,后面修改成自己的路径。

或者说你把core-site.xml拷贝你工程目录下。

或者说你将地址改成本机路径上的文件也是可以的。

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐