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 5ac6ee9ccb..f7cec35b80 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; } }