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 bh...@apache.org on 2019/02/20 01:01:39 UTC
[hadoop] branch trunk updated: Logging stale datanode information.
Contributed by Karthik Palanisamy.
This is an automated email from the ASF dual-hosted git repository.
bharat pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 51950f1 Logging stale datanode information. Contributed by Karthik Palanisamy.
51950f1 is described below
commit 51950f149ecc0b6f03849865031b12cdb5eecd5d
Author: Bharat Viswanadham <bh...@apache.org>
AuthorDate: Tue Feb 19 17:01:07 2019 -0800
Logging stale datanode information. Contributed by Karthik Palanisamy.
---
.../apache/hadoop/hdfs/server/blockmanagement/HeartbeatManager.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/HeartbeatManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/HeartbeatManager.java
index d2c279f..46444bc 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/HeartbeatManager.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/HeartbeatManager.java
@@ -379,6 +379,9 @@ class HeartbeatManager implements DatanodeStatistics {
dead = d;
}
if (d.isStale(dm.getStaleInterval())) {
+ LOG.warn(String.format("Stale datanode {}."
+ + " No heartbeat received since last {} milliseconds"),
+ d.getName(), dm.getStaleInterval());
numOfStaleNodes++;
}
DatanodeStorageInfo[] storageInfos = d.getStorageInfos();
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org