使用HDFS java api 创建文件出错。

李克华

使用HDFS java api 创建文件出错。

“//创建文件核心代码public static void createNewHDFSFile(String toCreateFilePath, String content) throws IOException{Configuration config = new Configuration();config.set("hadoop.job.ugi", "Administrator,supergroup");FileSystem hdfs = FileSystem.get(config);FSDataOutputStream os = hdfs.create(new Path(toCreateFilePath));os.write(content.getBytes("UTF-8"));os.close();hdfs.close();}