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

HBASE-9041 TestFlushSnapshotFromClient.testConcurrentSnapshottingAttempts fails; WRITE LESS ROWS 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1507024 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-07-25 15:47:21 +00:00
parent 387e323de4
commit d435dff509
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestFlushSnapshotFromClient.java
View File

@ -87,6 +87,7 @@ public class TestFlushSnapshotFromClient {
private static final byte[] TEST_FAM = Bytes.toBytes("fam"); private static final byte[] TEST_FAM = Bytes.toBytes("fam");
private static final byte[] TEST_QUAL = Bytes.toBytes("q"); private static final byte[] TEST_QUAL = Bytes.toBytes("q");
private static final byte[] TABLE_NAME = Bytes.toBytes(STRING_TABLE_NAME); private static final byte[] TABLE_NAME = Bytes.toBytes(STRING_TABLE_NAME);
private final int DEFAULT_NUM_ROWS = 100;
/** /**
* Setup the config for the cluster * Setup the config for the cluster
@ -159,7 +160,7 @@ public class TestFlushSnapshotFromClient {
// put some stuff in the table // put some stuff in the table
HTable table = new HTable(UTIL.getConfiguration(), TABLE_NAME); HTable table = new HTable(UTIL.getConfiguration(), TABLE_NAME);
loadData(table, 10000, TEST_FAM); loadData(table, DEFAULT_NUM_ROWS, TEST_FAM);
// get the name of all the regionservers hosting the snapshotted table // get the name of all the regionservers hosting the snapshotted table
Set<String> snapshotServers = new HashSet<String>(); Set<String> snapshotServers = new HashSet<String>();
@ -259,7 +260,7 @@ public class TestFlushSnapshotFromClient {
@Test @Test
public void testSnapshotStateAfterMerge() throws Exception { public void testSnapshotStateAfterMerge() throws Exception {
int numRows = 10000; int numRows = DEFAULT_NUM_ROWS;
HBaseAdmin admin = UTIL.getHBaseAdmin(); HBaseAdmin admin = UTIL.getHBaseAdmin();
// make sure we don't fail on listing snapshots // make sure we don't fail on listing snapshots
SnapshotTestingUtils.assertNoSnapshots(admin); SnapshotTestingUtils.assertNoSnapshots(admin);
@ -316,7 +317,7 @@ public class TestFlushSnapshotFromClient {
@Test @Test
public void testTakeSnapshotAfterMerge() throws Exception { public void testTakeSnapshotAfterMerge() throws Exception {
int numRows = 10000; int numRows = DEFAULT_NUM_ROWS;
HBaseAdmin admin = UTIL.getHBaseAdmin(); HBaseAdmin admin = UTIL.getHBaseAdmin();
// make sure we don't fail on listing snapshots // make sure we don't fail on listing snapshots
SnapshotTestingUtils.assertNoSnapshots(admin); SnapshotTestingUtils.assertNoSnapshots(admin);
@ -373,7 +374,7 @@ public class TestFlushSnapshotFromClient {
// make sure we don't fail on listing snapshots // make sure we don't fail on listing snapshots
SnapshotTestingUtils.assertNoSnapshots(admin); SnapshotTestingUtils.assertNoSnapshots(admin);
// load the table so we have some data // load the table so we have some data
loadData(new HTable(UTIL.getConfiguration(), TABLE_NAME), 10000, TEST_FAM); loadData(new HTable(UTIL.getConfiguration(), TABLE_NAME), DEFAULT_NUM_ROWS, TEST_FAM);
// and wait until everything stabilizes // and wait until everything stabilizes
waitForTableToBeOnline(TABLE_NAME); waitForTableToBeOnline(TABLE_NAME);
@ -444,8 +445,8 @@ public class TestFlushSnapshotFromClient {
// create second testing table // create second testing table
createTable(TABLE2_NAME, TEST_FAM); createTable(TABLE2_NAME, TEST_FAM);
// load the table so we have some data // load the table so we have some data
loadData(new HTable(UTIL.getConfiguration(), TABLE_NAME), 10000, TEST_FAM); loadData(new HTable(UTIL.getConfiguration(), TABLE_NAME), DEFAULT_NUM_ROWS, TEST_FAM);
loadData(new HTable(UTIL.getConfiguration(), TABLE2_NAME), 10000, TEST_FAM); loadData(new HTable(UTIL.getConfiguration(), TABLE2_NAME), DEFAULT_NUM_ROWS, TEST_FAM);
// and wait until everything stabilizes // and wait until everything stabilizes
waitForTableToBeOnline(TABLE_NAME); waitForTableToBeOnline(TABLE_NAME);
waitForTableToBeOnline(TABLE2_NAME); waitForTableToBeOnline(TABLE2_NAME);