|
@@ -133,6 +133,9 @@ public class CopyCommitter extends FileOutputCommitter {
|
|
private void deleteAttemptTempFiles(Path targetWorkPath,
|
|
private void deleteAttemptTempFiles(Path targetWorkPath,
|
|
FileSystem targetFS,
|
|
FileSystem targetFS,
|
|
String jobId) throws IOException {
|
|
String jobId) throws IOException {
|
|
|
|
+ if (targetWorkPath == null) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
|
|
FileStatus[] tempFiles = targetFS.globStatus(
|
|
FileStatus[] tempFiles = targetFS.globStatus(
|
|
new Path(targetWorkPath, ".distcp.tmp." + jobId.replaceAll("job","attempt") + "*"));
|
|
new Path(targetWorkPath, ".distcp.tmp." + jobId.replaceAll("job","attempt") + "*"));
|