3

在我的工作完成运行后,我有一个程序将文件分块上传到 S3。我必须做一些处理,这就是为什么我没有直接写入 S3。我使用了waitForCompletion,但我仍然收到org.apache.hadoop.hdfs.server.namenode.LeaseExpiredException _temporary 目录,该目录在我使用FileSystem 尝试打开文件之前被删除。

我的下一个选择是捕获异常并跳过文件,但有更好的选择吗?

4

0 回答 0