diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java index 0771c28243a..8841d99661e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java @@ -138,7 +138,8 @@ public class DatanodeAdminManager { try { cls = conf.getClass( DFSConfigKeys.DFS_NAMENODE_DECOMMISSION_MONITOR_CLASS, - DatanodeAdminDefaultMonitor.class); + Class.forName(DFSConfigKeys + .DFS_NAMENODE_DECOMMISSION_MONITOR_CLASS_DEFAULT)); monitor = (DatanodeAdminMonitorInterface)ReflectionUtils.newInstance(cls, conf); monitor.setBlockManager(blockManager);