You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2012/09/25 00:03:45 UTC
svn commit: r1389617 -
/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java
Author: larsh
Date: Mon Sep 24 22:03:45 2012
New Revision: 1389617
URL: http://svn.apache.org/viewvc?rev=1389617&view=rev
Log:
HBASE-6784 TestCoprocessorScanPolicy is sometimes flaky when run locally
Modified:
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java
Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java?rev=1389617&r1=1389616&r2=1389617&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestCoprocessorScanPolicy.java Mon Sep 24 22:03:45 2012
@@ -90,12 +90,14 @@ public class TestCoprocessorScanPolicy {
p.add(F, tableName, Bytes.toBytes(2));
t.put(p);
+ long now = EnvironmentEdgeManager.currentTimeMillis();
+
// insert 2 versions
p = new Put(R);
- p.add(F, Q, Q);
+ p.add(F, Q, now, Q);
t.put(p);
p = new Put(R);
- p.add(F, Q, Q);
+ p.add(F, Q, now+1, Q);
t.put(p);
Get g = new Get(R);
g.setMaxVersions(10);
@@ -113,7 +115,7 @@ public class TestCoprocessorScanPolicy {
// insert a 3rd version
p = new Put(R);
- p.add(F, Q, Q);
+ p.add(F, Q, now+2, Q);
t.put(p);
g = new Get(R);
g.setMaxVersions(10);