Repository: hbase Updated Branches: refs/heads/branch-1 5e9b6b8c3 -> bfaf83704
HBASE-13895 DATALOSS: Region assigned before WAL replay when abort (Enis Soztutar) -- ADDENDUM Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7b4febbc Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7b4febbc Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7b4febbc Branch: refs/heads/branch-1 Commit: 7b4febbc2b32ac09189af8508d40872fea46ad98 Parents: 09846ff Author: stack <st...@apache.org> Authored: Wed Jul 1 22:01:38 2015 -0700 Committer: stack <st...@apache.org> Committed: Thu Jul 2 10:05:58 2015 -0700 ---------------------------------------------------------------------- .../hadoop/hbase/master/TestAssignmentManager.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/7b4febbc/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java index b43138b..179b215 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java @@ -1628,10 +1628,10 @@ public class TestAssignmentManager { this.serverManager, balancer, null, null, master.getTableLockManager()); RegionStates regionStates = am.getRegionStates(); - regionStates.createRegionState(hri, State.OPEN, SERVERNAME_B, SERVERNAME_B); + regionStates.createRegionState(hri, State.OPEN, SERVERNAME_LIVE, SERVERNAME_LIVE); // mock aborting region server - Mockito.when(this.serverManager.sendRegionClose(Mockito.eq(SERVERNAME_B), Mockito.eq(REGIONINFO), + Mockito.when(this.serverManager.sendRegionClose(Mockito.eq(SERVERNAME_LIVE), Mockito.eq(REGIONINFO), Mockito.anyInt(), (ServerName)Mockito.any(), Mockito.anyBoolean())) .thenThrow(new RegionServerAbortedException("")); @@ -1640,7 +1640,7 @@ public class TestAssignmentManager { // assert that the we have FAILED_CLOSE for region state assertEquals(State.FAILED_CLOSE, regionStates.getRegionState(REGIONINFO).getState()); - assertEquals(SERVERNAME_B, regionStates.getRegionState(REGIONINFO).getServerName()); + assertEquals(SERVERNAME_LIVE, regionStates.getRegionState(REGIONINFO).getServerName()); am.shutdown(); } @@ -1665,10 +1665,10 @@ public class TestAssignmentManager { }; RegionStates regionStates = am.getRegionStates(); - regionStates.createRegionState(hri, State.OPEN, SERVERNAME_B, SERVERNAME_B); + regionStates.createRegionState(hri, State.OPEN, SERVERNAME_LIVE, SERVERNAME_LIVE); // mock that RS is expired, but not processed - Mockito.when(this.serverManager.isServerOnline(SERVERNAME_B)) + Mockito.when(this.serverManager.isServerOnline(SERVERNAME_LIVE)) .thenReturn(false); // try to unassign the region @@ -1679,7 +1679,7 @@ public class TestAssignmentManager { // try to assign the region before SSH am.regionPlans.put(REGIONINFO.getEncodedName(), - new RegionPlan(REGIONINFO, null, SERVERNAME_A)); + new RegionPlan(REGIONINFO, null, SERVERNAME_DEAD)); am.assign(hri, true, false); // assert that the we still have OFFLINE
