Преглед изворни кода

Fix incorrect heartbeat ack serialization in HDFS-724 for append 0.20. Contributed by Hairong Kuang.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.20-append@1035712 13f79535-47bb-0310-9956-ffa450edef68
Hairong Kuang пре 14 година
родитељ
комит
843aa1a24a
1 измењених фајлова са 3 додато и 8 уклоњено
  1. 3 8
      src/hdfs/org/apache/hadoop/hdfs/protocol/DataTransferProtocol.java

+ 3 - 8
src/hdfs/org/apache/hadoop/hdfs/protocol/DataTransferProtocol.java

@@ -120,14 +120,9 @@ public interface DataTransferProtocol {
       assert numRepliesExpected > 0;
       assert numRepliesExpected > 0;
 
 
       seqno = in.readLong();
       seqno = in.readLong();
-      if (seqno == HEARTBEAT_SEQNO) {
-        // Heartbeat doesn't forward any replies
-        replies = new short[0];
-      } else {
-        replies = new short[numRepliesExpected];
-        for (int i=0; i < replies.length; i++) {
-          replies[i] = in.readShort();
-        }
+      replies = new short[numRepliesExpected];
+      for (int i=0; i < replies.length; i++) {
+    	  replies[i] = in.readShort();
       }
       }
     }
     }