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