HDFS 自定义实现函数将文件追加到末尾的问题：

importorg.apache.hadoop.conf.Configuration;
importorg.apache.hadoop.fs.*;
importjava.io.*;
publicclassHDFSApi {
/*** 判断路径是否存在*/publicstaticbooleantest(Configurationconf, Stringpath) throwsIOException {
FileSystemfs=FileSystem.get(conf);
returnfs.exists(newPath(path));
    }
/*** 复制文件到指定路径* 若路径已存在，则进行覆盖*/publicstaticvoidcopyFromLocalFile(Configurationconf, StringlocalFilePath, StringremoteFilePath) throwsIOException {
FileSystemfs=FileSystem.get(conf);
PathlocalPath=newPath(localFilePath);
PathremotePath=newPath(remoteFilePath);
/* fs.copyFromLocalFile 第一个参数表示是否删除源文件，第二个参数表示是否覆盖 */fs.copyFromLocalFile(false, true, localPath, remotePath);
fs.close();
    }
/*** 追加文件内容*/publicstaticvoidappendToFile(Configurationconf, StringlocalFilePath, StringremoteFilePath) throwsIOException {
FileSystemfs=FileSystem.get(conf);
PathremotePath=newPath(remoteFilePath);
/* 创建一个文件读入流 */FileInputStreamin=newFileInputStream(localFilePath);
/* 创建一个文件输出流，输出的内容将追加到文件末尾 */FSDataOutputStreamout=fs.append(remotePath);
/* 读写文件内容 */byte[] data=newbyte[1024];
intread=-1;
while ( (read=in.read(data)) >0 ) {
out.write(data, 0, read);
        }
out.close();
in.close();
fs.close();
    }
/*** 主函数*/publicstaticvoidmain(String[] args) {
Configurationconf=newConfiguration();
conf.set("fs.default.name","hdfs://localhost:9000");
StringlocalFilePath="/home/hadoop/text.txt";    // 本地路径StringremoteFilePath="/user/hadoop/text.txt";    // HDFS路径Stringchoice="append";    // 若文件存在则追加到文件末尾//      String choice = "overwrite";    // 若文件存在则覆盖try {
/* 判断文件是否存在 */BooleanfileExists=false;
if (HDFSApi.test(conf, remoteFilePath)) {
fileExists=true;
System.out.println(remoteFilePath+" 已存在.");
            } else {
System.out.println(remoteFilePath+" 不存在.");
            }
/* 进行处理 */if ( !fileExists) { // 文件不存在，则上传HDFSApi.copyFromLocalFile(conf, localFilePath, remoteFilePath);
System.out.println(localFilePath+" 已上传至 "+remoteFilePath);
            } elseif ( choice.equals("overwrite") ) {    // 选择覆盖HDFSApi.copyFromLocalFile(conf, localFilePath, remoteFilePath);
System.out.println(localFilePath+" 已覆盖 "+remoteFilePath);
            } elseif ( choice.equals("append") ) {   // 选择追加HDFSApi.appendToFile(conf, localFilePath, remoteFilePath);
System.out.println(localFilePath+" 已追加至 "+remoteFilePath);
            }
        } catch (Exceptione) {
e.printStackTrace();
        }
    }
}

conf.set("dfs.client.block.write.replace-datanode-on-failure.policy","NEVER"); 
conf.set("dfs.client.block.write.replace-datanode-on-failure.enable","true");