Repository: hadoop Updated Branches: refs/heads/branch-2 8baf9369b -> 42160d358
HDFS-9597. BaseReplicationPolicyTest should update data node stats after adding a data node. Contributed by Wei-Chiu Chuang. (cherry picked from commit 8cfd672397efd91c471c417afef3aff85f64b506) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/42160d35 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/42160d35 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/42160d35 Branch: refs/heads/branch-2 Commit: 42160d358a8d010539603f777eafcc806d983c21 Parents: 8baf936 Author: Benoy Antony <[email protected]> Authored: Fri Dec 25 08:55:39 2015 -0800 Committer: Benoy Antony <[email protected]> Committed: Fri Dec 25 08:57:34 2015 -0800 ---------------------------------------------------------------------- .../hdfs/server/blockmanagement/BaseReplicationPolicyTest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/42160d35/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(); }
