You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by su...@apache.org on 2013/10/16 23:11:04 UTC
svn commit: r1532912 -
/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
Author: suresh
Date: Wed Oct 16 21:11:03 2013
New Revision: 1532912
URL: http://svn.apache.org/r1532912
Log:
HADOOP-10005. Merge 1532908 from branch-2
Modified:
hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java?rev=1532912&r1=1532911&r2=1532912&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java (original)
+++ hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java Wed Oct 16 21:11:03 2013
@@ -1310,15 +1310,13 @@ public class DataNode extends Configured
int numTargets = xferTargets.length;
if (numTargets > 0) {
- if (LOG.isInfoEnabled()) {
- StringBuilder xfersBuilder = new StringBuilder();
- for (int i = 0; i < numTargets; i++) {
- xfersBuilder.append(xferTargets[i]);
- xfersBuilder.append(" ");
- }
- LOG.info(bpReg + " Starting thread to transfer " +
- block + " to " + xfersBuilder);
+ StringBuilder xfersBuilder = new StringBuilder();
+ for (int i = 0; i < numTargets; i++) {
+ xfersBuilder.append(xferTargets[i]);
+ xfersBuilder.append(" ");
}
+ LOG.info(bpReg + " Starting thread to transfer " +
+ block + " to " + xfersBuilder);
new Daemon(new DataTransfer(xferTargets, block,
BlockConstructionStage.PIPELINE_SETUP_CREATE, "")).start();