From b25c35089fe854166b4f7a57171fa21abeb99a5f Mon Sep 17 00:00:00 2001 From: Zilong Zhu Date: Mon, 29 Apr 2024 22:44:43 +0800 Subject: [PATCH] HDFS-17503. Unreleased volume references because of OOM. --- .../org/apache/hadoop/hdfs/server/datanode/BlockSender.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java index 5ac6ee9ccbdaf..f7cec35b80d5e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java @@ -434,12 +434,12 @@ class BlockSender implements java.io.Closeable { blockIn = datanode.data.getBlockInputStream(block, offset); // seek to offset ris = new ReplicaInputStreams( blockIn, checksumIn, volumeRef, fileIoProvider); - } catch (IOException ioe) { + } catch (Throwable t) { IOUtils.cleanupWithLogger(null, volumeRef); IOUtils.closeStream(this); IOUtils.closeStream(blockIn); IOUtils.closeStream(checksumIn); - throw ioe; + throw t; } }