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 d2c279f8b4a..46444bc9b26 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();