hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From szets...@apache.org
Subject svn commit: r1135209 - in /hadoop/common/trunk/mapreduce: CHANGES.txt src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java
Date Mon, 13 Jun 2011 18:16:45 GMT
Author: szetszwo
Date: Mon Jun 13 18:16:45 2011
New Revision: 1135209

URL: http://svn.apache.org/viewvc?rev=1135209&view=rev
Log:
MAPREDUCE-2588. Change raid to the new DataTransferProtocol API.

Modified:
    hadoop/common/trunk/mapreduce/CHANGES.txt
    hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java
    hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java

Modified: hadoop/common/trunk/mapreduce/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/mapreduce/CHANGES.txt?rev=1135209&r1=1135208&r2=1135209&view=diff
==============================================================================
--- hadoop/common/trunk/mapreduce/CHANGES.txt (original)
+++ hadoop/common/trunk/mapreduce/CHANGES.txt Mon Jun 13 18:16:45 2011
@@ -290,6 +290,8 @@ Trunk (unreleased changes)
 
     MAPREDUCE-2581. Spelling errors in log messages. (Tim Sell via eli)
 
+    MAPREDUCE-2588. Change raid to the new DataTransferProtocol API.  (szetszwo)
+
 Release 0.22.0 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java?rev=1135209&r1=1135208&r2=1135209&view=diff
==============================================================================
--- hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java
(original)
+++ hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java
Mon Jun 13 18:16:45 2011
@@ -32,7 +32,7 @@ import org.apache.commons.logging.Log;
 import org.apache.hadoop.fs.ChecksumException;
 import org.apache.hadoop.hdfs.protocol.ExtendedBlock;
 import org.apache.hadoop.hdfs.protocol.FSConstants;
-import org.apache.hadoop.hdfs.protocol.DataTransferProtocol.PacketHeader;
+import org.apache.hadoop.hdfs.protocol.datatransfer.PacketHeader;
 import org.apache.hadoop.io.IOUtils;
 import org.apache.hadoop.net.SocketOutputStream;
 import org.apache.hadoop.util.DataChecksum;

Modified: hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java?rev=1135209&r1=1135208&r2=1135209&view=diff
==============================================================================
--- hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java
(original)
+++ hadoop/common/trunk/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java
Mon Jun 13 18:16:45 2011
@@ -43,7 +43,7 @@ import java.lang.reflect.InvocationTarge
 
 import org.apache.hadoop.util.DataChecksum;
 import org.apache.hadoop.hdfs.DistributedFileSystem;
-import org.apache.hadoop.hdfs.protocol.DataTransferProtocol;
+import org.apache.hadoop.hdfs.protocol.datatransfer.*;
 import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
 import org.apache.hadoop.hdfs.protocol.ExtendedBlock;
 import org.apache.hadoop.hdfs.protocol.FSConstants;
@@ -780,8 +780,7 @@ public abstract class BlockFixer extends
                               });
         
         DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
-        DataTransferProtocol.Sender.opWriteBlock(out, block.getBlock(), 1,
-                                                 DataTransferProtocol.
+        Sender.opWriteBlock(out, block.getBlock(), 1,
                                                  BlockConstructionStage.
                                                  PIPELINE_SETUP_CREATE,
                                                  0, blockSize, 0, "", null,



Mime
View raw message