diff --git a/mapreduce/CHANGES.txt b/mapreduce/CHANGES.txt index 0a0b16d02e..3d798db9be 100644 --- a/mapreduce/CHANGES.txt +++ b/mapreduce/CHANGES.txt @@ -383,6 +383,8 @@ Trunk (unreleased changes) MAPREDUCE-2797. Update mapreduce tests and RAID for HDFS-2239. (szetszwo) + MAPREDUCE-2805. Update RAID for HDFS-2241. (szetszwo) + Release 0.22.0 - Unreleased INCOMPATIBLE CHANGES diff --git a/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java b/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java index f55e69e5fc..337deaeedf 100644 --- a/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java +++ b/mapreduce/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/datanode/RaidBlockSender.java @@ -41,7 +41,7 @@ /** * Reads a block from the disk and sends it to a recipient. */ -public class RaidBlockSender implements java.io.Closeable, FSConstants { +public class RaidBlockSender implements java.io.Closeable { public static final Log LOG = DataNode.LOG; static final Log ClientTraceLog = DataNode.ClientTraceLog; @@ -389,7 +389,7 @@ public long sendBlock(DataOutputStream out, OutputStream baseStream) streamForSendChunks = baseStream; // assure a mininum buffer size. - maxChunksPerPacket = (Math.max(BUFFER_SIZE, + maxChunksPerPacket = (Math.max(FSConstants.IO_FILE_BUFFER_SIZE, MIN_BUFFER_WITH_TRANSFERTO) + bytesPerChecksum - 1)/bytesPerChecksum; @@ -397,7 +397,7 @@ public long sendBlock(DataOutputStream out, OutputStream baseStream) pktSize += checksumSize * maxChunksPerPacket; } else { maxChunksPerPacket = Math.max(1, - (BUFFER_SIZE + bytesPerChecksum - 1)/bytesPerChecksum); + (FSConstants.IO_FILE_BUFFER_SIZE + bytesPerChecksum - 1)/bytesPerChecksum); pktSize += (bytesPerChecksum + checksumSize) * maxChunksPerPacket; }