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

HDFS-9748. Avoid duplication in pendingReplications when addExpectedReplicasToPending is called twice. Contributed by Walter Su.

Browse Source
This commit is contained in:
Jing Zhao 2016-02-03 13:30:09 -08:00
parent fa328e2d39
commit 7badf15604
3 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -2693,6 +2693,9 @@ Release 2.8.0 - UNRELEASED
HDFS-9739. DatanodeStorage.isValidStorageId() is broken
(Mingliang Liu via vinayakumarb)
HDFS-9748. Avoid duplication in pendingReplications when
addExpectedReplicasToPending is called twice. (Walter Su via jing9)
Release 2.7.3 - UNRELEASED
INCOMPATIBLE CHANGES

9
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/PendingReplicationBlocks.java
View File

@ -23,7 +23,6 @@
import java.sql.Time;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
@ -77,7 +76,7 @@ void start() {
* @param block The corresponding block
* @param targets The DataNodes where replicas of the block should be placed
*/
void increment(BlockInfo block, DatanodeDescriptor[] targets) {
void increment(BlockInfo block, DatanodeDescriptor... targets) {
synchronized (pendingReplications) {
PendingBlockInfo found = pendingReplications.get(block);
if (found == null) {
@ -193,7 +192,11 @@ void setTimeStamp() {
void incrementReplicas(DatanodeDescriptor... newTargets) {
if (newTargets != null) {
Collections.addAll(targets, newTargets);
for (DatanodeDescriptor newTarget : newTargets) {
if (!targets.contains(newTarget)) {
targets.add(newTarget);
}
}
}
}

9
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestPendingReplication.java
View File

@ -80,13 +80,20 @@ public void testPendingReplication() {
//
// remove one item and reinsert it
// remove one item
//
BlockInfo blk = genBlockInfo(8, 8, 0);
pendingReplications.decrement(blk, storages[7].getDatanodeDescriptor()); // removes one replica
assertEquals("pendingReplications.getNumReplicas ",
7, pendingReplications.getNumReplicas(blk));
//
// insert the same item twice should be counted as once
//
pendingReplications.increment(blk, storages[0].getDatanodeDescriptor());
assertEquals("pendingReplications.getNumReplicas ",
7, pendingReplications.getNumReplicas(blk));
for (int i = 0; i < 7; i++) {
// removes all replicas
pendingReplications.decrement(blk, storages[i].getDatanodeDescriptor());