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 e060cabd80b..767d36e92ed 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 @@ -622,10 +622,10 @@ private int sendPacket(ByteBuffer pkt, int maxChunks, OutputStream out, String ioem = e.getMessage(); if (!ioem.startsWith("Broken pipe") && !ioem.startsWith("Connection reset")) { LOG.error("BlockSender.sendChunks() exception: ", e); - } - datanode.getBlockScanner().markSuspectBlock( + datanode.getBlockScanner().markSuspectBlock( volumeRef.getVolume().getStorageID(), block); + } } throw ioeToSocketException(e); }