|
@@ -23,6 +23,7 @@ import java.io.*;
|
|
|
import java.util.*;
|
|
|
import org.apache.hadoop.conf.Configuration;
|
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
|
+import org.apache.hadoop.fs.FileUtil;
|
|
|
import org.apache.hadoop.fs.Path;
|
|
|
|
|
|
/**
|
|
@@ -59,7 +60,7 @@ public class TestStreamingFailure extends TestStreaming
|
|
|
{
|
|
|
try {
|
|
|
try {
|
|
|
- OUTPUT_DIR.getAbsoluteFile().delete();
|
|
|
+ FileUtil.fullyDelete(OUTPUT_DIR.getAbsoluteFile());
|
|
|
} catch (Exception e) {
|
|
|
}
|
|
|
|