Przeglądaj źródła

HDFS-14624. When decommissioning a node, log remaining blocks to replicate periodically. Contributed by Stephen O'Donnell.

Inigo Goiri 6 lat temu
rodzic
commit
5747f6cff5

+ 7 - 5
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java

@@ -506,8 +506,10 @@ public class DatanodeAdminManager {
         namesystem.writeUnlock();
       }
       if (numBlocksChecked + numNodesChecked > 0) {
-        LOG.info("Checked {} blocks and {} nodes this tick", numBlocksChecked,
-            numNodesChecked);
+        LOG.info("Checked {} blocks and {} nodes this tick. {} nodes are now " +
+            "in maintenance or transitioning state. {} nodes pending.",
+            numBlocksChecked, numNodesChecked, outOfServiceNodeBlocks.size(),
+            pendingNodes.size());
       }
     }
 
@@ -598,14 +600,14 @@ public class DatanodeAdminManager {
               LOG.debug("Node {} is sufficiently replicated and healthy, "
                   + "marked as {}.", dn, dn.getAdminState());
             } else {
-              LOG.debug("Node {} {} healthy."
+              LOG.info("Node {} {} healthy."
                   + " It needs to replicate {} more blocks."
                   + " {} is still in progress.", dn,
                   isHealthy ? "is": "isn't", blocks.size(), dn.getAdminState());
             }
           } else {
-            LOG.debug("Node {} still has {} blocks to replicate "
-                + "before it is a candidate to finish {}.",
+            LOG.info("Node {} still has {} blocks to replicate "
+                    + "before it is a candidate to finish {}.",
                 dn, blocks.size(), dn.getAdminState());
           }
         } catch (Exception e) {