|
@@ -622,10 +622,10 @@ class BlockSender implements java.io.Closeable {
|
|
String ioem = e.getMessage();
|
|
String ioem = e.getMessage();
|
|
if (!ioem.startsWith("Broken pipe") && !ioem.startsWith("Connection reset")) {
|
|
if (!ioem.startsWith("Broken pipe") && !ioem.startsWith("Connection reset")) {
|
|
LOG.error("BlockSender.sendChunks() exception: ", e);
|
|
LOG.error("BlockSender.sendChunks() exception: ", e);
|
|
- }
|
|
|
|
- datanode.getBlockScanner().markSuspectBlock(
|
|
|
|
|
|
+ datanode.getBlockScanner().markSuspectBlock(
|
|
volumeRef.getVolume().getStorageID(),
|
|
volumeRef.getVolume().getStorageID(),
|
|
block);
|
|
block);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
throw ioeToSocketException(e);
|
|
throw ioeToSocketException(e);
|
|
}
|
|
}
|