You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ki...@apache.org on 2016/10/20 15:52:08 UTC
hadoop git commit: HDFS-10627. Volume Scanner marks a block as
"suspect" even if the exception is network-related. Contributed by Rushabh S
Shah.
Repository: hadoop
Updated Branches:
refs/heads/trunk 4c73be135 -> 5c0bffddc
HDFS-10627. Volume Scanner marks a block as "suspect" even if the exception is network-related. Contributed by Rushabh S Shah.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/5c0bffdd
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/5c0bffdd
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/5c0bffdd
Branch: refs/heads/trunk
Commit: 5c0bffddc0cb824a8a2751bcd0dc3e15ce081727
Parents: 4c73be1
Author: Kihwal Lee <ki...@apache.org>
Authored: Thu Oct 20 10:48:35 2016 -0500
Committer: Kihwal Lee <ki...@apache.org>
Committed: Thu Oct 20 10:48:35 2016 -0500
----------------------------------------------------------------------
.../java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/5c0bffdd/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockSender.java
----------------------------------------------------------------------
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 c3ba2eb..bfc53f1 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 @@ class BlockSender implements java.io.Closeable {
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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org