|
@@ -1232,7 +1232,8 @@ public class TestReplicationPolicy {
|
|
|
when(storage.getState()).thenReturn(DatanodeStorage.State.NORMAL);
|
|
|
when(storage.getDatanodeDescriptor()).thenReturn(dn);
|
|
|
when(storage.removeBlock(any(BlockInfo.class))).thenReturn(true);
|
|
|
- when(storage.addBlock(any(BlockInfo.class))).thenReturn(true);
|
|
|
+ when(storage.addBlock(any(BlockInfo.class))).thenReturn
|
|
|
+ (DatanodeStorageInfo.AddBlockResult.ADDED);
|
|
|
ucBlock.addStorage(storage);
|
|
|
|
|
|
when(mbc.setLastBlock((BlockInfo) any(), (DatanodeStorageInfo[]) any()))
|