hadoop报错Wrong FS: hdfs:/, expected: file:///

在hadoop-2.2.0版本中对hdfs进行简单的测试操作，代码如下所示

Configuration conf = new Configuration();
       try {
           FileSystem fs = FileSystem.get(conf);
           Path f = new Path("hdfs:///dfs_operator.txt");
           FSDataOutputStream os = fs.create(f, true);
           int i = 0;
           for (i = 0; i < 10; ++i)
               os.writeChars("test");
           os.close();
       } catch (IOException e) {
           e.printStackTrace();
       }

执行报错信息如下：

Exception in thread "main" java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.eclipse.jdt.internal.jarinjarloader.JarRsrcLoader.main(JarRsrcLoader.java:58)
Caused by: java.lang.IllegalArgumentException: Wrong FS: hdfs:/, expected: file:///
at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:642)
at org.apache.hadoop.fs.RawLocalFileSystem.pathToFile(RawLocalFileSystem.java:69)
at org.apache.hadoop.fs.RawLocalFileSystem.mkdirs(RawLocalFileSystem.java:419)
at org.apache.hadoop.fs.ChecksumFileSystem.mkdirs(ChecksumFileSystem.java:584)
at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:437)
at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:424)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:905)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:886)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:783)
at com.ailk.hadoopdemo.DFSOperator.main(DFSOperator.java:22)
... 5 more
解决方法一：

// explicitely add other config files// PASS A PATH NOT A STRING!
conf.addResource(newPath("/home/hadoop/conf/core-site.xml"));
解决方法二：

把hadoop集群上的core-site.xml和hdfs-site.xml放到工程的src目录下

原文：https://blog.csdn.net/u014470581/article/details/51480600

hadoop报错Wrong FS: hdfs:/, expected: file:///相关推荐

hadoop程序问题：java.lang.IllegalArgumentException: Wrong FS: hdfs:/ expected file:///
FileSystem fs = FileSystem.get(conf); in=fs.open(newPath("hdfs://192.168.130.54:19000/user/hmai ...
hadoop 报错 there appears to be a gap in the edit log. we expected txitd 1, but got txid 14444
hadoop 报错 there appears to be a gap in the edit log. we expected txitd 1, but got txid 14444 原因: na ...
2021-08-10 HDFS Web报错Couldn‘t preview the file.
在查看文件内容时,在红框位置出现报错"Couldn't preview the file" 解决方法第一步:修改hdfs-site.xml,添加配置信息 <property ...
重新编译CDH版本hadoop报错：Non-resolvable parent POM: Could not transfer artifact com.
重新编译CDH版本hadoop报错: Could not transfer artifact com.cloudera.cdh:cdh-root:pom:5.14.0 from/to cdh.repo ...
linux:can't open file for write,解决 Linux-Ubuntu 报错E212: Can't open file for writing
为了装spark,先装Hadoop: 为了装Hadoop,先搭建Linux环境和设置环境变量,于是有了本文的报错"E212: Can't open file for writing" ...
Hadoop报错信息：Job not successful. Error: # of failed Map Tasks exceeded allowed limit. FailedCount: 4.
Hadoop报错信息如下: 120 15/01/27 15:48:23 ERROR streaming.StreamJob: Job not successful. Error: # of faile ...
scp报错：not a regular file
2019独角兽企业重金招聘Python工程师标准>>> linux 本地文件上传到服务器 scp /home/XXX/file.1txt liujia@172.16.252.32: ...
Hadoop报错：All specified directories are failed to load.
Hadoop报错:All specified directories are failed to load. 先将所有的Hadoop进程停掉,然后清空将所有节点的Hadoop的安装目录下的data目录 ...
sudo vi ~/etc/profile 报错E212:Can't open file for writing
linux系统,安装SPARK时, 命令行窗口输入:sudo vi ~/etc/profile 输入: #SPARK_HOME SPARK_HOME=/home/luoji/JAVA/spark-2. ...

hadoop报错Wrong FS: hdfs:/, expected: file:///

hadoop报错Wrong FS: hdfs:/, expected: file:///相关推荐

最新文章

热门文章