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 ar...@apache.org on 2017/03/18 02:06:30 UTC
[2/2] hadoop git commit: HDFS-11547. Add logs for slow BlockReceiver
while writing data to disk. Contributed by Xiaobing Zhou.
HDFS-11547. Add logs for slow BlockReceiver while writing data to disk. Contributed by Xiaobing Zhou.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/5d7197b2
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/5d7197b2
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/5d7197b2
Branch: refs/heads/branch-2
Commit: 5d7197b2e6ac127a29778ca56b5a6db652dd5b0e
Parents: e44569b
Author: Arpit Agarwal <ar...@apache.org>
Authored: Fri Mar 17 19:02:24 2017 -0700
Committer: Arpit Agarwal <ar...@apache.org>
Committed: Fri Mar 17 19:03:41 2017 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/5d7197b2/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 8fc1a2f..11ae7b0 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
@@ -711,6 +711,10 @@ class BlockReceiver implements Closeable {
streams.writeDataToDisk(dataBuf.array(),
startByteToDisk, numBytesToDisk);
long duration = Time.monotonicNow() - begin;
+ if (duration > datanodeSlowLogThresholdMs) {
+ LOG.warn("Slow BlockReceiver write data to disk cost:" + duration
+ + "ms (threshold=" + datanodeSlowLogThresholdMs + "ms)");
+ }
if (duration > maxWriteToDiskMs) {
maxWriteToDiskMs = duration;
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org