博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Hadoop创建/删除文件夹出错
阅读量:5052 次
发布时间:2019-06-12

本文共 2264 字,大约阅读时间需要 7 分钟。

log4j:WARN No appenders could be found for logger (org.apache.hadoop.metrics2.lib.MutableMetricsFactory).

log4j:WARN Please initialize the log4j system properly.
log4j:WARN See for more info.
Exception in thread "main" java.lang.IllegalArgumentException: Wrong FS: hdfs://sandbox.hortonworks.com:8020/user/testdir, expected: file:///
    at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:645)
    at org.apache.hadoop.fs.RawLocalFileSystem.pathToFile(RawLocalFileSystem.java:80)
    at org.apache.hadoop.fs.RawLocalFileSystem.mkdirs(RawLocalFileSystem.java:423)
    at org.apache.hadoop.fs.ChecksumFileSystem.mkdirs(ChecksumFileSystem.java:590)
    at com.hdfs.directory.CreateDir.main(CreateDir.java:19)
在本机运行是会出现上面的错误,改成下面的代码:

package com.hdfs.directory;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;public class CreateDir {    /**     * @param args     * @throws IOException      */    public static void main(String[] args) throws IOException {        // TODO Auto-generated method stub        Configuration conf=new Configuration();        Path newPath = new Path("hdfs://sandbox.hortonworks.com:8020/user/testdir");        //FileSystem fs=FileSystem.get(conf);        FileSystem fs = newPath.getFileSystem(conf);        fs.mkdirs(newPath);        fs.close();//        FileStatus fileStatus=fs.getFileStatus(new Path("/user/long1657/20130908"));            }}

或者hadoop相关的配置信息,放在工程目录下:

 

执行上面的代码后:/user/testdir目录被成功删除:

 

在将hadoop相关的配置文件添加到工程中后,用下面的代码就可以成功创建文件夹:

package com.hdfs.directory;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;public class CreateDirWithConf {    /**     * @param args     * @throws IOException      */    public static void main(String[] args) throws IOException {        // TODO Auto-generated method stub        Configuration conf=new Configuration();            FileSystem fs=FileSystem.get(conf);        fs.mkdirs(new Path("hdfs://sandbox.hortonworks.com:8020/user/testdir"));        fs.close();//        FileStatus fileStatus=fs.getFileStatus(new Path("/user/long1657/20130908"));            }}

 

转载于:https://www.cnblogs.com/justinzhang/p/4844137.html

你可能感兴趣的文章
●数组及应用举例
查看>>
个人作业2——英语学习APP案例分析
查看>>
Oracle中的数据字典技术初级入门
查看>>
Java Build Practice 1:Ant
查看>>
3.RxJava详解
查看>>
【小波变换】STL版 一维离散小波变换(DWT)库,完全按matlab的wavelet toolbox 的API实现的...
查看>>
作业六:小学生四则运算之NABCD模型与产品Backlog。
查看>>
__int128的实现
查看>>
R 读取clipboard内容 (MAC)
查看>>
Problem - 1118B - Codeforces(Tanya and Candies)
查看>>
jdk1.8 api 下载
查看>>
svn 图标不显示
查看>>
getElement的几中属性介绍
查看>>
iOS 使用Quartz 2D画虚线 【转】
查看>>
平面最接近点对
查看>>
HTML列表,表格与媒体元素
查看>>
PHP、Java、Python、C、C++ 这几种编程语言都各有什么特点或优点?
查看>>
ApplicationDelegate里的方法
查看>>
C#中给WebClient添加代理Proxy
查看>>
py 的 第 10 天
查看>>