You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jd...@apache.org on 2010/12/20 23:08:29 UTC
svn commit: r1051302 -
/hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java
Author: jdcryans
Date: Mon Dec 20 22:08:29 2010
New Revision: 1051302
URL: http://svn.apache.org/viewvc?rev=1051302&view=rev
Log:
Fix for failing test
Modified:
hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java
Modified: hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java?rev=1051302&r1=1051301&r2=1051302&view=diff
==============================================================================
--- hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java (original)
+++ hbase/trunk/src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java Mon Dec 20 22:08:29 2010
@@ -72,6 +72,8 @@ public class TestReplication {
private static HBaseTestingUtility utility1;
private static HBaseTestingUtility utility2;
private static final int NB_ROWS_IN_BATCH = 100;
+ private static final int NB_ROWS_IN_BIG_BATCH =
+ NB_ROWS_IN_BATCH * 10;
private static final long SLEEP_TIME = 500;
private static final int NB_RETRIES = 10;
@@ -173,7 +175,7 @@ public class TestReplication {
fail("Waited too much time for truncate");
}
ResultScanner scanner = htable2.getScanner(scan);
- Result[] res = scanner.next(NB_ROWS_IN_BATCH);
+ Result[] res = scanner.next(NB_ROWS_IN_BIG_BATCH);
scanner.close();
if (res.length != 0) {
if (lastCount < res.length) {
@@ -417,7 +419,7 @@ public class TestReplication {
public void loadTesting() throws Exception {
htable1.setWriteBufferSize(1024);
htable1.setAutoFlush(false);
- for (int i = 0; i < NB_ROWS_IN_BATCH *10; i++) {
+ for (int i = 0; i < NB_ROWS_IN_BIG_BATCH; i++) {
Put put = new Put(Bytes.toBytes(i));
put.add(famName, row, row);
htable1.put(put);
@@ -427,7 +429,7 @@ public class TestReplication {
Scan scan = new Scan();
ResultScanner scanner = htable1.getScanner(scan);
- Result[] res = scanner.next(NB_ROWS_IN_BATCH * 100);
+ Result[] res = scanner.next(NB_ROWS_IN_BIG_BATCH);
scanner.close();
assertEquals(NB_ROWS_IN_BATCH *10, res.length);
@@ -437,9 +439,9 @@ public class TestReplication {
for (int i = 0; i < NB_RETRIES; i++) {
scanner = htable2.getScanner(scan);
- res = scanner.next(NB_ROWS_IN_BATCH * 100);
+ res = scanner.next(NB_ROWS_IN_BIG_BATCH);
scanner.close();
- if (res.length != NB_ROWS_IN_BATCH *10) {
+ if (res.length != NB_ROWS_IN_BIG_BATCH) {
if (i == NB_RETRIES-1) {
int lastRow = -1;
for (Result result : res) {
@@ -451,7 +453,7 @@ public class TestReplication {
}
LOG.error("Last row: " + lastRow);
fail("Waited too much time for normal batch replication, "
- + res.length + " instead of " + NB_ROWS_IN_BATCH *10);
+ + res.length + " instead of " + NB_ROWS_IN_BIG_BATCH);
} else {
LOG.info("Only got " + res.length + " rows");
Thread.sleep(SLEEP_TIME);