This is an automated email from the ASF dual-hosted git repository. surendralilhore pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push: new 3468164 HDFS-14719. Correct the safemode threshold value in BlockManagerSafeMode. Contributed by hemanthboyina. 3468164 is described below commit 34681643e92774da6f74826c468ecec4dcbedf5a Author: Surendra Singh Lilhore <surendralilh...@apache.org> AuthorDate: Thu Aug 15 12:12:18 2019 +0530 HDFS-14719. Correct the safemode threshold value in BlockManagerSafeMode. Contributed by hemanthboyina. --- .../hadoop/hdfs/server/blockmanagement/BlockManagerSafeMode.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManagerSafeMode.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManagerSafeMode.java index 3f59b64..87b3968 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManagerSafeMode.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManagerSafeMode.java @@ -85,7 +85,7 @@ class BlockManagerSafeMode { private volatile BMSafeModeStatus status = BMSafeModeStatus.OFF; /** Safe mode threshold condition %.*/ - private final double threshold; + private final float threshold; /** Number of blocks needed to satisfy safe mode threshold condition. */ private long blockThreshold; /** Total number of blocks. */ @@ -97,7 +97,7 @@ class BlockManagerSafeMode { /** Min replication required by safe mode. */ private final int safeReplication; /** Threshold for populating needed replication queues. */ - private final double replQueueThreshold; + private final float replQueueThreshold; /** Number of blocks needed before populating replication queues. */ private long blockReplQueueThreshold; @@ -150,8 +150,7 @@ class BlockManagerSafeMode { // default to safe mode threshold (i.e., don't populate queues before // leaving safe mode) this.replQueueThreshold = - conf.getFloat(DFS_NAMENODE_REPL_QUEUE_THRESHOLD_PCT_KEY, - (float) threshold); + conf.getFloat(DFS_NAMENODE_REPL_QUEUE_THRESHOLD_PCT_KEY, threshold); this.extension = conf.getTimeDuration(DFS_NAMENODE_SAFEMODE_EXTENSION_KEY, DFS_NAMENODE_SAFEMODE_EXTENSION_DEFAULT, MILLISECONDS); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org