From 4163eb56b679f21739ad9a279b3d4b675810f60f Mon Sep 17 00:00:00 2001 From: Viraj Jasani Date: Wed, 7 Apr 2021 15:34:18 +0530 Subject: [PATCH 1/2] HDFS-15940. Error log for replica recovery failure --- .../apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java index 03d5851f23257..df09048d4d85a 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java @@ -257,6 +257,7 @@ public void testRaceBetweenReplicaRecoveryAndFinalizeBlock() dataNode.initReplicaRecovery(recoveringBlock); } } catch (Exception e) { + LOG.error("Something went wrong.", e); recoveryInitResult.set(false); } }); From e0c8b8999e9b637ef3192b1adb98f9a86617ca09 Mon Sep 17 00:00:00 2001 From: Viraj Jasani Date: Thu, 8 Apr 2021 00:35:17 +0530 Subject: [PATCH 2/2] update Xceiver stop timeout --- .../hadoop/hdfs/server/datanode/TestBlockRecovery2.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java index df09048d4d85a..8d2df18711256 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java @@ -229,8 +229,8 @@ public void testRaceBetweenReplicaRecoveryAndFinalizeBlock() tearDown(); Configuration configuration = new HdfsConfiguration(); - configuration.set( - DFSConfigKeys.DFS_DATANODE_XCEIVER_STOP_TIMEOUT_MILLIS_KEY, "1000"); + configuration.setLong( + DFSConfigKeys.DFS_DATANODE_XCEIVER_STOP_TIMEOUT_MILLIS_KEY, 5000L); MiniDFSCluster cluster = new MiniDFSCluster.Builder(configuration) .numDataNodes(1).build(); try {