HDFS-17342. Fix UT

apache · Jan 20, 2024 · 0a93644 · 0a93644
1 parent 34ff23b
commit 0a93644
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...rc/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestFsDatasetImpl.java b/...rc/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestFsDatasetImpl.java
@@ -1962,7 +1962,7 @@ public void delayDeleteReplica() {
    *     4. block would be recovered when disk back to normal.
    */
   @Test
-  public void tesInvalidateMissingBlock() throws Exception {
+  public void testInvalidateMissingBlock() throws Exception {
     long blockSize = 1024;
     int heartbeatInterval = 1;
     HdfsConfiguration c = new HdfsConfiguration();
@@ -2060,7 +2060,9 @@ public void delayGetMetaDataInputStream() {
         Future<?> blockReaderFuture = executorService.submit(() -> {
           try {
             // Submit tasks for reading block.
-            BlockReaderTestUtil.getBlockReader(cluster.getFileSystem(), blk, 0, 512);
+            BlockReader blockReader = BlockReaderTestUtil.getBlockReader(
+                cluster.getFileSystem(), blk, 0, 512);
+            blockReader.close();
           } catch (IOException e) {
             // Ignore exception.
           }