Hadoop JAVA端错误案例

import com.google.inject.internal.cglib.core.$ClassInfo;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

public class HdfsFS_Demo_02 {
FileSystem fs=null;
@Before
public void init() throws Exception {
//1、配置信息对象 用户自定义设置 比如设置副本个数 切块大小
Configuration conf = new Configuration();
//2、获取hdfs客户端对象
/*
* 参数一 URI
* 参数二 配置对象
* 参数三 用户
* */
fs = FileSystem.newInstance(new URI(“hdfs://linux01:8020”),conf,“root”);
// 错误案例
// FileSystem fs = FileSystem.newInstance(new URI(“hdfs://linux01:8020”),conf,“root”);
}
@Test
public void testMkdir() throws Exception {
// 上传文件到hdfs
fs.mkdirs(new Path("/sdfsdf/sdf"));
fs.close();
}

@Test
public void testMV() throws Exception {
    //  改名  移动
    fs.rename(new Path("/img"),new Path("/sdfsdf/"));
    fs.close();
}

}