This is an automated email from the ASF dual-hosted git repository. surendralilhore pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push: new 96f7dc1 HDFS-14796. Define LOG instead of BlockManager.LOG in ErasureCodingWork/ReplicationWork. Contributed by Fei Hui. 96f7dc1 is described below commit 96f7dc1992246a16031f613e55dc39ea0d64acd1 Author: Surendra Singh Lilhore <surendralilh...@apache.org> AuthorDate: Fri Aug 30 14:28:13 2019 +0530 HDFS-14796. Define LOG instead of BlockManager.LOG in ErasureCodingWork/ReplicationWork. Contributed by Fei Hui. --- .../hdfs/server/blockmanagement/BlockReconstructionWork.java | 6 ++++++ .../hadoop/hdfs/server/blockmanagement/ErasureCodingWork.java | 8 +++----- .../hadoop/hdfs/server/blockmanagement/ReplicationWork.java | 3 +-- 3 files changed, 10 insertions(+), 7 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockReconstructionWork.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockReconstructionWork.java index d383191..df76a15 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockReconstructionWork.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockReconstructionWork.java @@ -18,6 +18,8 @@ package org.apache.hadoop.hdfs.server.blockmanagement; import org.apache.hadoop.net.Node; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.util.Collections; import java.util.List; @@ -30,6 +32,10 @@ import java.util.Set; * Reconstruction is done by transferring data from srcNodes to targets */ abstract class BlockReconstructionWork { + + public static final Logger LOG = + LoggerFactory.getLogger(BlockReconstructionWork.class); + private final BlockInfo block; private final String srcPath; diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingWork.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingWork.java index 147f8cf..f0e6d49 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingWork.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingWork.java @@ -44,7 +44,7 @@ class ErasureCodingWork extends BlockReconstructionWork { liveReplicaStorages, additionalReplRequired, priority); this.blockPoolId = blockPoolId; this.liveBlockIndicies = liveBlockIndicies; - BlockManager.LOG.debug("Creating an ErasureCodingWork to {} reconstruct ", + LOG.debug("Creating an ErasureCodingWork to {} reconstruct ", block); } @@ -157,10 +157,8 @@ class ErasureCodingWork extends BlockReconstructionWork { internBlkLen, stripedBlk.getGenerationStamp()); source.addBlockToBeReplicated(targetBlk, new DatanodeStorageInfo[] {target}); - if (BlockManager.LOG.isDebugEnabled()) { - BlockManager.LOG.debug("Add replication task from source {} to " - + "target {} for EC block {}", source, target, targetBlk); - } + LOG.debug("Add replication task from source {} to " + + "target {} for EC block {}", source, target, targetBlk); } private List<Integer> findLeavingServiceSources() { diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ReplicationWork.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ReplicationWork.java index f250bcb..5e10ebe 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ReplicationWork.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ReplicationWork.java @@ -32,8 +32,7 @@ class ReplicationWork extends BlockReconstructionWork { assert getSrcNodes().length == 1 : "There should be exactly 1 source node that have been selected"; getSrcNodes()[0].incrementPendingReplicationWithoutTargets(); - BlockManager.LOG - .debug("Creating a ReplicationWork to reconstruct " + block); + LOG.debug("Creating a ReplicationWork to reconstruct " + block); } @Override --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org