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

HBASE-18551 [AMv2] UnassignProcedure and crashed regionservers; AMENDMENT -- disable TestAM#testSocketTimeout... mock is insufficent for new processing

This commit is contained in:
Michael Stack 2017-08-11 14:20:06 -07:00
parent b5a4e07c6a
commit 7197b40cbf
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.java
View File

@ -243,7 +243,7 @@ public class TestAssignmentManager {
} }
} }
@Test @Ignore @Test // Disabled for now. Since HBASE-18551, this mock is insufficient.
public void testSocketTimeout() throws Exception { public void testSocketTimeout() throws Exception {
final TableName tableName = TableName.valueOf(this.name.getMethodName()); final TableName tableName = TableName.valueOf(this.name.getMethodName());
final HRegionInfo hri = createRegionInfo(tableName, 1); final HRegionInfo hri = createRegionInfo(tableName, 1);
@ -254,9 +254,8 @@ public class TestAssignmentManager {
rsDispatcher.setMockRsExecutor(new SocketTimeoutRsExecutor(20, 3)); rsDispatcher.setMockRsExecutor(new SocketTimeoutRsExecutor(20, 3));
waitOnFuture(submitProcedure(am.createAssignProcedure(hri, false))); waitOnFuture(submitProcedure(am.createAssignProcedure(hri, false)));
rsDispatcher.setMockRsExecutor(new SocketTimeoutRsExecutor(20, 3)); rsDispatcher.setMockRsExecutor(new SocketTimeoutRsExecutor(20, 1));
// exception.expect(ServerCrashException.class);
exception.expect(ServerCrashException.class);
waitOnFuture(submitProcedure(am.createUnassignProcedure(hri, null, false))); waitOnFuture(submitProcedure(am.createUnassignProcedure(hri, null, false)));
assertEquals(assignSubmittedCount + 1, assignProcMetrics.getSubmittedCounter().getCount()); assertEquals(assignSubmittedCount + 1, assignProcMetrics.getSubmittedCounter().getCount());