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 ay...@apache.org on 2020/12/21 20:47:32 UTC
[hadoop] branch trunk updated: HDFS-15308.
TestReconstructStripedFile#testNNSendsErasureCodingTasks fails
intermittently. Contributed by Hemanth Boyina.
This is an automated email from the ASF dual-hosted git repository.
ayushsaxena 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 ba496f6 HDFS-15308. TestReconstructStripedFile#testNNSendsErasureCodingTasks fails intermittently. Contributed by Hemanth Boyina.
ba496f6 is described below
commit ba496f61f8acb5cda91cc72f4af34274a436ebe0
Author: Ayush Saxena <ay...@apache.org>
AuthorDate: Tue Dec 22 02:07:51 2020 +0530
HDFS-15308. TestReconstructStripedFile#testNNSendsErasureCodingTasks fails intermittently. Contributed by Hemanth Boyina.
---
.../java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java
index b24dfe3..c4c263a 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java
@@ -468,7 +468,7 @@ public class TestReconstructStripedFile {
final int numDataNodes = dnNum + 1;
conf.setInt(
- DFSConfigKeys.DFS_NAMENODE_RECONSTRUCTION_PENDING_TIMEOUT_SEC_KEY, 10);
+ DFSConfigKeys.DFS_NAMENODE_RECONSTRUCTION_PENDING_TIMEOUT_SEC_KEY, 1);
conf.setInt(DFSConfigKeys.DFS_NAMENODE_REPLICATION_MAX_STREAMS_KEY, 20);
conf.setInt(DFSConfigKeys.DFS_DN_EC_RECONSTRUCTION_THREADS_KEY,
2);
@@ -504,8 +504,9 @@ public class TestReconstructStripedFile {
// Make sure that all pending reconstruction tasks can be processed.
while (ns.getPendingReconstructionBlocks() > 0) {
long timeoutPending = ns.getNumTimedOutPendingReconstructions();
- assertTrue(String.format("Found %d timeout pending reconstruction tasks",
- timeoutPending), timeoutPending == 0);
+ assertEquals(String
+ .format("Found %d timeout pending reconstruction tasks",
+ timeoutPending), 0, timeoutPending);
Thread.sleep(1000);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org