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

HBASE-5659 TestAtomicOperation.testMultiRowMutationMultiThreads is still failing occasionally 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1364501 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
larsh 2012-07-23 05:24:26 +00:00
parent c48ac29ca9
commit 889e1136d4
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
View File

@ -522,7 +522,7 @@ class StoreScanner extends NonLazyKeyValueScanner
if (this.heap == null && this.lastTop != null) {
resetScannerStack(this.lastTop);
if (this.heap.peek() == null
|| store.comparator.compare(this.lastTop, this.heap.peek()) != 0) {
|| store.comparator.compareRows(this.lastTop, this.heap.peek()) != 0) {
LOG.debug("Storescanner.peek() is changed where before = "
+ this.lastTop.toString() + ",and after = " + this.heap.peek());
this.lastTop = null;

6
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
View File

@ -255,7 +255,7 @@ public class TestAtomicOperation extends HBaseTestCase {
LOG.info("Starting test testRowMutationMultiThreads");
initHRegion(tableName, getName(), fam1);
// create 100 threads, each will alternate between adding and
// create 10 threads, each will alternate between adding and
// removing a column
int numThreads = 10;
int opsPerThread = 500;
@ -339,10 +339,10 @@ public class TestAtomicOperation extends HBaseTestCase {
LOG.info("Starting test testMultiRowMutationMultiThreads");
initHRegion(tableName, getName(), fam1);
// create 100 threads, each will alternate between adding and
// create 10 threads, each will alternate between adding and
// removing a column
int numThreads = 10;
int opsPerThread = 1000;
int opsPerThread = 500;
AtomicOperation[] all = new AtomicOperation[numThreads];
AtomicLong timeStamps = new AtomicLong(0);