HDFS-10667. Report more accurate info about data corruption location. (Yuanbo Liu via Yongjun Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/eb7ff0c9 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/eb7ff0c9 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/eb7ff0c9 Branch: refs/heads/HADOOP-12756 Commit: eb7ff0c9927131f4a797148b970a95a1abf7d847 Parents: 54fe17a Author: Yongjun Zhang <yzh...@cloudera.com> Authored: Wed Jul 27 13:58:04 2016 -0700 Committer: Yongjun Zhang <yzh...@cloudera.com> Committed: Wed Jul 27 13:58:04 2016 -0700 ---------------------------------------------------------------------- .../apache/hadoop/hdfs/server/datanode/BlockReceiver.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/eb7ff0c9/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java index 8f9138c..b6f0b01 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java @@ -470,7 +470,13 @@ class BlockReceiver implements Closeable { try { clientChecksum.verifyChunkedSums(dataBuf, checksumBuf, clientname, 0); } catch (ChecksumException ce) { - LOG.warn("Checksum error in block " + block + " from " + inAddr, ce); + PacketHeader header = packetReceiver.getHeader(); + String specificOffset = "specific offsets are:" + + " offsetInBlock = " + header.getOffsetInBlock() + + " offsetInPacket = " + ce.getPos(); + LOG.warn("Checksum error in block " + + block + " from " + inAddr + + ", " + specificOffset, ce); // No need to report to namenode when client is writing. if (srcDataNode != null && isDatanode) { try { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
