HDFS-12642. Log block and datanode details in BlockRecoveryWorker.
(cherry picked from commit 971b3ca1acc15d9a1f8e774291813dafd16ef704)
This commit is contained in:
parent
db726c4483
commit
6a55d0e671
|
@ -184,10 +184,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.
|
||||
|
@ -276,6 +275,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) {
|
||||
|
@ -327,7 +331,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()
|
||||
|
|
Loading…
Reference in New Issue