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 su...@apache.org on 2019/10/09 17:59:49 UTC
[hadoop] branch trunk updated: HDFS-14754. Erasure Coding : The
number of Under-Replicated Blocks never reduced(addendum). Contributed by
Surendra Singh Lilhore.
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 d76e265 HDFS-14754. Erasure Coding : The number of Under-Replicated Blocks never reduced(addendum). Contributed by Surendra Singh Lilhore.
d76e265 is described below
commit d76e2655ace56490a92da70bde9e651ce515f80c
Author: Surendra Singh Lilhore <su...@apache.org>
AuthorDate: Wed Oct 9 23:20:28 2019 +0530
HDFS-14754. Erasure Coding : The number of Under-Replicated Blocks never reduced(addendum). Contributed by Surendra Singh Lilhore.
---
.../hadoop/hdfs/server/namenode/TestRedudantBlocks.java | 14 +++++++++-----
1 file changed, 9 insertions(+), 5 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestRedudantBlocks.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestRedudantBlocks.java
index 943699a..ac25da3 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestRedudantBlocks.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestRedudantBlocks.java
@@ -58,7 +58,7 @@ public class TestRedudantBlocks {
private final int cellSize = ecPolicy.getCellSize();
private final int stripesPerBlock = 4;
private final int blockSize = stripesPerBlock * cellSize;
- private final int numDNs = groupSize + 1;
+ private final int numDNs = groupSize;
@Before
public void setup() throws IOException {
@@ -110,12 +110,16 @@ public class TestRedudantBlocks {
// update blocksMap
cluster.triggerBlockReports();
- // add to invalidates
+ // delete redundant block
cluster.triggerHeartbeats();
- // datanode delete block
+ //wait for IBR
+ Thread.sleep(1100);
+
+ // trigger reconstruction
cluster.triggerHeartbeats();
- // update blocksMap
- cluster.triggerBlockReports();
+
+ //wait for IBR
+ Thread.sleep(1100);
HashSet<Long> blockIdsSet = new HashSet<Long>();
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org