From 8ee060311c89b7faa71dd039481a97ba15e2413d Mon Sep 17 00:00:00 2001 From: Yongjun Zhang Date: Thu, 28 Jan 2016 22:53:26 -0800 Subject: [PATCH] HDFS-9706. Log more details in debug logs in BlockReceiver's constructor. (Xiao Chen via Yongjun Zhang) --- hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt | 3 +++ .../hdfs/server/datanode/BlockReceiver.java | 18 ++++++++++++------ 2 files changed, 15 insertions(+), 6 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 9b80aa16af1..570caa5cd3d 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -1860,6 +1860,9 @@ Release 2.8.0 - UNRELEASED HDFS-8898. Create API and command-line argument to get quota and quota usage without detailed content summary. (Ming Ma via kihwal) + HDFS-9706. Log more details in debug logs in BlockReceiver's constructor. + (Xiao Chen via Yongjun Zhang) + OPTIMIZATIONS HDFS-8026. Trace FSOutputSummer#writeChecksumChunks rather than 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 e7908a5d1e4..0dc8cabdf94 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 @@ -187,12 +187,18 @@ class BlockReceiver implements Closeable { this.maxSendIdleTime = (long) (readTimeout * 0.9); if (LOG.isDebugEnabled()) { LOG.debug(getClass().getSimpleName() + ": " + block - + "\n isClient =" + isClient + ", clientname=" + clientname - + "\n isDatanode=" + isDatanode + ", srcDataNode=" + srcDataNode - + "\n inAddr=" + inAddr + ", myAddr=" + myAddr - + "\n cachingStrategy = " + cachingStrategy - + "\n pinning=" + pinning - ); + + "\n storageType=" + storageType + ", inAddr=" + inAddr + + ", myAddr=" + myAddr + "\n stage=" + stage + ", newGs=" + newGs + + ", minBytesRcvd=" + minBytesRcvd + + ", maxBytesRcvd=" + maxBytesRcvd + "\n clientname=" + clientname + + ", srcDataNode=" + srcDataNode + + ", datanode=" + datanode.getDisplayName() + + "\n requestedChecksum=" + requestedChecksum + + "\n cachingStrategy=" + cachingStrategy + + "\n allowLazyPersist=" + allowLazyPersist + ", pinning=" + pinning + + ", isClient=" + isClient + ", isDatanode=" + isDatanode + + ", responseInterval=" + responseInterval + ); } //