|
@@ -181,11 +181,10 @@ public class DirectoryCollection {
|
|
|
long utilizationSpaceCutOff) {
|
|
|
conf = new YarnConfiguration();
|
|
|
try {
|
|
|
- diskValidator = DiskValidatorFactory.getInstance(
|
|
|
- conf.get(YarnConfiguration.DISK_VALIDATOR,
|
|
|
- YarnConfiguration.DEFAULT_DISK_VALIDATOR));
|
|
|
- LOG.info("Disk Validator: " + YarnConfiguration.DISK_VALIDATOR +
|
|
|
- " is loaded.");
|
|
|
+ String diskValidatorName = conf.get(YarnConfiguration.DISK_VALIDATOR,
|
|
|
+ YarnConfiguration.DEFAULT_DISK_VALIDATOR);
|
|
|
+ diskValidator = DiskValidatorFactory.getInstance(diskValidatorName);
|
|
|
+ LOG.info("Disk Validator '" + diskValidatorName + "' is loaded.");
|
|
|
} catch (Exception e) {
|
|
|
throw new YarnRuntimeException(e);
|
|
|
}
|