2016-12-20 11 views
0

hadoopバージョン2.6.0を使用していて、HDFSの既存のファイルにデータを追加しようとしていますが、それは私にとってはうまくいかないようです。ここに私の方法は、FileSystem.Append機能を使用してHDFSに書き込む方法です。Java APIを使用して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()関数はうまく動作します。 は、私はこのエラーを得た:

は、ファイル/test_dir_10/append_data_to_this_file.txtのクローズに失敗しました。リース 回復が進行中です。あとでもう一度試してみてください。

私はまたhdsf-site.xmlにする

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

をだから、誰もが私が欠けていたり間違ってやってアイデアを持って、このプロパティを追加しましたか?おかげさまで

答えて

0

問題は、ファイルシステム上で実行することによって解決された

hadoop dfs -setrep -R -w 2/
関連する問題