java - 如何使用Java API将数据附加到HDFS中的现有文件？

Question

我正在使用hadoop版本2.6.0，并尝试将数据追加到HDFS中的现有文件中，但似乎对我不起作用。这是我使用FileSystem.Append函数写入HDFS的方法。

HdfsIO hdfsIO = new HdfsIO(hdfsCoreSite,hdfsSite);
FileSystem fs = FileSystem.get(hdfsIO.getConfiguration());
FSDataOutputStream out = fs.append(new Path("/test_dir_10/append_data_to_this_file.txt"));
out.writeUTF("Append demo...");
fs.close();

Write()和create()函数可以很好地工作，但是append()函数却可以。
我收到此错误:

Failed to close file /test_dir_10/append_data_to_this_file.txt. Lease recovery is in progress. Try again later.

我也将此属性添加到hdsf-site.xml

<property> 
    <name>dfs.support.append</name>
    <value>true</value> 
</property>

所以有人知道我想念什么或做错了什么吗？
谢谢。

Answer 1

通过在文件系统上运行解决了问题

hadoop dfs -setrep -R -w 2 /