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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
