Logging stale datanode information. Contributed by Karthik Palanisamy.

2019-02-19 17:01:07 -08:00 · 2019-02-19 17:01:07 -08:00 · 51950f149e
parent e8d7e3b4e6
commit 51950f149e
1 changed files with 3 additions and 0 deletions
--- 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();