|
@@ -387,8 +387,8 @@ public class TestBlocksWithNotEnoughRacks {
|
|
|
|
|
|
// Configure an excludes file
|
|
// Configure an excludes file
|
|
FileSystem localFileSys = FileSystem.getLocal(conf);
|
|
FileSystem localFileSys = FileSystem.getLocal(conf);
|
|
- Path workingDir = localFileSys.getWorkingDirectory();
|
|
|
|
- Path dir = new Path(workingDir, "build/test/data/temp/decommission");
|
|
|
|
|
|
+ Path workingDir = new Path(MiniDFSCluster.getBaseDirectory());
|
|
|
|
+ Path dir = new Path(workingDir, "temp/decommission");
|
|
Path excludeFile = new Path(dir, "exclude");
|
|
Path excludeFile = new Path(dir, "exclude");
|
|
Path includeFile = new Path(dir, "include");
|
|
Path includeFile = new Path(dir, "include");
|
|
assertTrue(localFileSys.mkdirs(dir));
|
|
assertTrue(localFileSys.mkdirs(dir));
|
|
@@ -440,8 +440,8 @@ public class TestBlocksWithNotEnoughRacks {
|
|
|
|
|
|
// Configure an excludes file
|
|
// Configure an excludes file
|
|
FileSystem localFileSys = FileSystem.getLocal(conf);
|
|
FileSystem localFileSys = FileSystem.getLocal(conf);
|
|
- Path workingDir = localFileSys.getWorkingDirectory();
|
|
|
|
- Path dir = new Path(workingDir, "build/test/data/temp/decommission");
|
|
|
|
|
|
+ Path workingDir = new Path(MiniDFSCluster.getBaseDirectory());
|
|
|
|
+ Path dir = new Path(workingDir, "temp/decommission");
|
|
Path excludeFile = new Path(dir, "exclude");
|
|
Path excludeFile = new Path(dir, "exclude");
|
|
Path includeFile = new Path(dir, "include");
|
|
Path includeFile = new Path(dir, "include");
|
|
assertTrue(localFileSys.mkdirs(dir));
|
|
assertTrue(localFileSys.mkdirs(dir));
|