diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockReportLease.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockReportLease.java index 2d05d700a2fe6..02f1fbcb5fe3e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockReportLease.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockReportLease.java @@ -283,7 +283,7 @@ public void testFirstIncompleteBlockReport() throws Exception { cluster.waitActive(); FSNamesystem fsn = cluster.getNamesystem(); - + NameNode nameNode = cluster.getNameNode(); // pretend to be in safemode NameNodeAdapter.enterSafeMode(nameNode, false); @@ -337,10 +337,6 @@ public void testFirstIncompleteBlockReport() throws Exception { // Wait until BlockManager calls processReport delayer.waitForCall(); - // Remove full block report lease about dn - spyBlockManager.getBlockReportLeaseManager() - .removeLease(datanodeDescriptor); - // Allow blockreport to proceed delayer.proceed();