HADOOP-3029. Datanode prints log message "firstbadlink" only if

it detects a bad connection to another datanode in the pipeline. (dhruba)



git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@638544 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -269,6 +269,9 @@ Trunk (unreleased changes)
     
     HADOOP-3006. Fix wrong packet size reported by DataNode when a block
     is being replicated. (rangadi)
+
+    HADOOP-3029. Datanode prints log message "firstbadlink" only if 
+    it detects a bad connection to another datanode in the pipeline. (dhruba)
     
 Release 0.16.2 - Unreleased
 

src/java/org/apache/hadoop/dfs/DataNode.java

@@ -1138,10 +1138,12 @@ public class DataNode implements FSConstants, Runnable {
             // read connect ack (only for clients, not for replication req)
             if (client.length() != 0) {
               firstBadLink = Text.readString(mirrorIn);
-              LOG.info("Datanode " + targets.length +
-                       " got response for connect ack " +
-                       " from downstream datanode with firstbadlink as " +
-                       firstBadLink);
+              if (LOG.isDebugEnabled() || firstBadLink.length() > 0) {
+                LOG.info("Datanode " + targets.length +
+                         " got response for connect ack " +
+                         " from downstream datanode with firstbadlink as " +
+                         firstBadLink);
+              }
             }
 
           } catch (IOException e) {
@@ -1161,9 +1163,11 @@ public class DataNode implements FSConstants, Runnable {
 
         // send connect ack back to source (only for clients)
         if (client.length() != 0) {
-          LOG.info("Datanode " + targets.length +
-                   " forwarding connect ack to upstream firstbadlink is " +
-                   firstBadLink);
+          if (LOG.isDebugEnabled() || firstBadLink.length() > 0) {
+            LOG.info("Datanode " + targets.length +
+                     " forwarding connect ack to upstream firstbadlink is " +
+                     firstBadLink);
+          }
           Text.writeString(replyOut, firstBadLink);
           replyOut.flush();
         }