HDFS-12642. Log block and datanode details in BlockRecoveryWorker.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/21bc8555 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/21bc8555 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/21bc8555 Branch: refs/heads/YARN-1011 Commit: 21bc85558718490e558c5b3bdb44c9c64eada994 Parents: 7bd7009 Author: Xiao Chen <x...@apache.org> Authored: Mon Oct 16 10:33:16 2017 -0700 Committer: Xiao Chen <x...@apache.org> Committed: Mon Oct 16 10:34:06 2017 -0700 ---------------------------------------------------------------------- .../hdfs/server/datanode/BlockRecoveryWorker.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/21bc8555/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockRecoveryWorker.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockRecoveryWorker.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockRecoveryWorker.java index 15c4af1..2ecd986 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockRecoveryWorker.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockRecoveryWorker.java @@ -197,10 +197,9 @@ public class BlockRecoveryWorker { long blockId = (isTruncateRecovery) ? rBlock.getNewBlock().getBlockId() : block.getBlockId(); - if (LOG.isDebugEnabled()) { - LOG.debug("block=" + block + ", (length=" + block.getNumBytes() - + "), syncList=" + syncList); - } + LOG.info("BlockRecoveryWorker: block={} (length={})," + + " isTruncateRecovery={}, syncList={}", block, + block.getNumBytes(), isTruncateRecovery, syncList); // syncList.isEmpty() means that all data-nodes do not have the block // or their replicas have 0 length. @@ -289,6 +288,11 @@ public class BlockRecoveryWorker { newBlock.setNumBytes(rBlock.getNewBlock().getNumBytes()); } + LOG.info("BlockRecoveryWorker: block={} (length={}), bestState={}," + + " newBlock={} (length={}), participatingList={}", + block, block.getNumBytes(), bestState.name(), newBlock, + newBlock.getNumBytes(), participatingList); + List<DatanodeID> failedList = new ArrayList<>(); final List<BlockRecord> successList = new ArrayList<>(); for (BlockRecord r : participatingList) { @@ -542,7 +546,7 @@ public class BlockRecoveryWorker { ExtendedBlock block = rb.getBlock(); DatanodeInfo[] targets = rb.getLocations(); - LOG.info(who + " calls recoverBlock(" + block + LOG.info("BlockRecoveryWorker: " + who + " calls recoverBlock(" + block + ", targets=[" + Joiner.on(", ").join(targets) + "]" + ", newGenerationStamp=" + rb.getNewGenerationStamp() + ", newBlock=" + rb.getNewBlock() --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
