ジョブの実行が終了した直後に、ファイルを S3 にチャンクでアップロードするプログラムが実行されます。いくつかの処理を行う必要があるため、S3 に直接書き込みませんでした。私はwaitForCompletionを使用しましたが、FileSystemを使用してファイルを開こうとする前に削除される_temporaryディレクトリのorg.apache.hadoop.hdfs.server.namenode.LeaseExpiredExceptionをまだ取得しています。
私の次のオプションは、例外をキャッチしてファイルをスキップすることですが、より良いオプションはありますか?