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 18:34:04 UTC

[hadoop] branch branch-3.1 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 branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/branch-3.1 by this push:
     new b396ebd  HDFS-14754. Erasure Coding : The number of Under-Replicated Blocks never reduced(addendum). Contributed by Surendra Singh Lilhore.
b396ebd is described below

commit b396ebd0d5d98f91bea0d2130d2cdd660d5fb102
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.
    
    (cherry picked from commit d76e2655ace56490a92da70bde9e651ce515f80c)
---
 .../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