Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-11818. TestBlockManager.testSufficientlyReplBlocksUsesNewRack fails intermittently. Contributed by Nathan Roberts

Browse Source 
(cherry picked from commit aeca471ec13135064f9605174cd6daa120007b18)
This commit is contained in:
Jason Lowe 2017-05-12 17:47:17 -05:00
parent dfa2657abf
commit f42222a75b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManager.java
View File

@ -153,7 +153,6 @@ public void setupMockCluster() throws IOException {
Mockito.when(haContext.getState()).thenReturn(haState); Mockito.when(haContext.getState()).thenReturn(haState);
Mockito.when(haState.shouldPopulateReplQueues()).thenReturn(true); Mockito.when(haState.shouldPopulateReplQueues()).thenReturn(true);
Mockito.when(fsn.getHAContext()).thenReturn(haContext); Mockito.when(fsn.getHAContext()).thenReturn(haContext);
bm.setInitializedReplQueues(true);
CacheManager cm = Mockito.mock(CacheManager.class); CacheManager cm = Mockito.mock(CacheManager.class);
Mockito.doReturn(cm).when(fsn).getCacheManager(); Mockito.doReturn(cm).when(fsn).getCacheManager();
GSet<CachedBlock, CachedBlock> cb = GSet<CachedBlock, CachedBlock> cb =
@ -897,10 +896,12 @@ public void testUCBlockNotConsideredMissing() throws Exception {
StorageReceivedDeletedBlocks srdb = StorageReceivedDeletedBlocks srdb =
new StorageReceivedDeletedBlocks(new DatanodeStorage(ds.getStorageID()), new StorageReceivedDeletedBlocks(new DatanodeStorage(ds.getStorageID()),
rdbiList.toArray(new ReceivedDeletedBlockInfo[rdbiList.size()])); rdbiList.toArray(new ReceivedDeletedBlockInfo[rdbiList.size()]));
bm.setInitializedReplQueues(true);
bm.processIncrementalBlockReport(node, srdb); bm.processIncrementalBlockReport(node, srdb);
// Needed replications should still be 0. // Needed replications should still be 0.
assertEquals("UC block was incorrectly added to needed Replications", assertEquals("UC block was incorrectly added to needed Replications",
0, bm.neededReplications.size()); 0, bm.neededReplications.size());
bm.setInitializedReplQueues(false);
} }
private BlockInfo addBlockToBM(long blkId) { private BlockInfo addBlockToBM(long blkId) {