You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by be...@apache.org on 2015/12/25 17:56:01 UTC
hadoop git commit: HDFS-9597. BaseReplicationPolicyTest should update
data node stats after adding a data node. Contributed by Wei-Chiu Chuang.
Repository: hadoop
Updated Branches:
refs/heads/trunk 2c17b8156 -> 8cfd67239
HDFS-9597. BaseReplicationPolicyTest should update data node stats after adding a data node. Contributed by Wei-Chiu Chuang.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8cfd6723
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8cfd6723
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8cfd6723
Branch: refs/heads/trunk
Commit: 8cfd672397efd91c471c417afef3aff85f64b506
Parents: 2c17b81
Author: Benoy Antony <be...@apache.org>
Authored: Fri Dec 25 08:55:39 2015 -0800
Committer: Benoy Antony <be...@apache.org>
Committed: Fri Dec 25 08:55:39 2015 -0800
----------------------------------------------------------------------
.../hdfs/server/blockmanagement/BaseReplicationPolicyTest.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/8cfd6723/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/BaseReplicationPolicyTest.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/BaseReplicationPolicyTest.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/BaseReplicationPolicyTest.java
index 6174447..7dc52fa 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/BaseReplicationPolicyTest.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/BaseReplicationPolicyTest.java
@@ -98,6 +98,8 @@ abstract public class BaseReplicationPolicyTest {
cluster.add(dataNodes[i]);
bm.getDatanodeManager().getHeartbeatManager().addDatanode(
dataNodes[i]);
+ bm.getDatanodeManager().getHeartbeatManager().updateDnStat(
+ dataNodes[i]);
}
updateHeartbeatWithUsage();
}