big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-2620. Update RAID for HDFS-2087.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1139400 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Tsz-wo Sze 2011-06-24 18:21:55 +00:00
parent 4c4eed13d5
commit d09e2475b6
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mapreduce/CHANGES.txt
View File

@ -310,6 +310,8 @@ Trunk (unreleased changes)
MAPREDUCE-2550. Fix bin/mapred to work properly from within a source MAPREDUCE-2550. Fix bin/mapred to work properly from within a source
checkout (Eric Yang via todd) checkout (Eric Yang via todd)
MAPREDUCE-2620. Update RAID for HDFS-2087. (szetszwo)
Release 0.22.0 - Unreleased Release 0.22.0 - Unreleased
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

8
mapreduce/src/contrib/raid/src/java/org/apache/hadoop/raid/BlockFixer.java
View File

@ -780,11 +780,9 @@ private void sendFixedBlock(DatanodeInfo datanode,
}); });
DatanodeInfo[] nodes = new DatanodeInfo[]{datanode}; DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
Sender.opWriteBlock(out, block.getBlock(), 1, new Sender(out).writeBlock(block.getBlock(), block.getBlockToken(), "",
BlockConstructionStage. nodes, null, BlockConstructionStage.PIPELINE_SETUP_CREATE,
PIPELINE_SETUP_CREATE, 1, 0L, blockSize, 0L);
0, blockSize, 0, "", null,
nodes, block.getBlockToken());
blockSender.sendBlock(out, baseStream); blockSender.sendBlock(out, baseStream);
LOG.info("Sent block " + block.getBlock() + " to " + datanode.name); LOG.info("Sent block " + block.getBlock() + " to " + datanode.name);