cloudera快速启动vm illegalarguementexception:错误的fs:hdfs:预期：文件：

qzlgjiam 于 2021-05-29 发布在 Hadoop

关注(0)|答案(2)|浏览(291)

我有一个简单的java代码将文本文件从本地复制到hdfs。我正在使用cloudera的快速启动虚拟机。

Configuration conf = new Configuration();
conf.addResource(new Path("/etc/hadoop/conf/core-site.xml"));
conf.addResource(new Path("/etc/hadoop/conf/hdfs-site.xml"));
FileSystem fs = FileSystem.get(conf);
fs.copyFromLocalFile(new Path("/home/cloudera/workspace/Downloader/output/data.txt"), 
                          new Path("hdfs://quickstart.cloudera:8020/user/cloudera/"));

运行此代码后出现以下错误：

Exception in thread "main" java.lang.IllegalArgumentException: Wrong FS: hdfs://quickstart.cloudera:8020/user/cloudera, expected: file:///
at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:381)
at org.apache.hadoop.fs.RawLocalFileSystem.pathToFile(RawLocalFileSystem.java:55)
at org.apache.hadoop.fs.LocalFileSystem.pathToFile(LocalFileSystem.java:61)
at org.apache.hadoop.fs.LocalFileSystem.exists(LocalFileSystem.java:51)
at org.apache.hadoop.fs.FileUtil.checkDest(FileUtil.java:355)
at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:211)
at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:163)
at org.apache.hadoop.fs.LocalFileSystem.copyFromLocalFile(LocalFileSystem.java:67)
at org.apache.hadoop.fs.FileSystem.copyFromLocalFile(FileSystem.java:1143)

我会做错什么？

Java hadoop cloudera-quickstart-vm eclipse

来源：https://stackoverflow.com/questions/33267367/cloudera-quickstart-vm-illegalarguementexception-wrong-fs-hdfs-expected-file

2条答案

按热度按时间

jgovgodb1#

路径不正确（“hdfs://quickstart.cloudera：8020/user/cloudera/“使用以下示例：

Configuration conf = getConf();
System.out.println("fs.default.name : - " + conf.get("fs.default.name"));
// It prints uri  as : hdfs://10.214.15.165:9000 or something...
String uri = conf.get("fs.default.name");
FileSystem fs = FileSystem.get(uri,getConf());

赞(0）回复(0）举报 2021-05-30

bt1cpqcv2#

我解决了这个问题。您必须小心添加到类路径的jar文件的类型，尤其是在使用cloudera quickstart vm时。如果可用，请使用cloudera提供的jar文件。它们可以在这个文件夹中找到：/usr/lib/hadoop/client/这段代码可以正常工作，没有任何问题。

Configuration conf = new Configuration();
conf.addResource(new Path("/etc/hadoop/conf/core-site.xml"));
conf.addResource(new Path("/etc/hadoop/conf/hdfs-site.xml"));
FileSystem fs = FileSystem.get(conf);
fs.copyFromLocalFile(new Path("/home/cloudera/workspace/Downloader/output/data.txt"), 
                      new Path("hdfs://quickstart.cloudera:8020/user/cloudera/"));

赞(0）回复(0）举报 2021-05-30

我来回答

cloudera快速启动vm illegalarguementexception:错误的fs:hdfs:预期：文件：

2条答案

相关问题

热门标签

最新问答