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

HBASE-22003 Fix flaky test TestVerifyReplication.testHBase14905

Browse Source
This commit is contained in:
Guanghao 2019-05-28 17:22:53 +08:00 committed by Guanghao Zhang
parent 9a89ea53d2
commit 90c13d5970
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyReplication.java
View File

@ -252,11 +252,12 @@ public class TestVerifyReplication extends TestReplicationBase {
// normal Batch tests // normal Batch tests
byte[] qualifierName = Bytes.toBytes("f1"); byte[] qualifierName = Bytes.toBytes("f1");
Put put = new Put(Bytes.toBytes("r1")); Put put = new Put(Bytes.toBytes("r1"));
put.addColumn(famName, qualifierName, Bytes.toBytes("v1002")); long ts = System.currentTimeMillis();
put.addColumn(famName, qualifierName, ts + 1, Bytes.toBytes("v1002"));
htable1.put(put); htable1.put(put);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1001")); put.addColumn(famName, qualifierName, ts + 2, Bytes.toBytes("v1001"));
htable1.put(put); htable1.put(put);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1112")); put.addColumn(famName, qualifierName, ts + 3, Bytes.toBytes("v1112"));
htable1.put(put); htable1.put(put);
Scan scan = new Scan(); Scan scan = new Scan();
@ -291,9 +292,9 @@ public class TestVerifyReplication extends TestReplicationBase {
} }
} }
put.addColumn(famName, qualifierName, Bytes.toBytes("v1111")); put.addColumn(famName, qualifierName, ts + 4, Bytes.toBytes("v1111"));
htable2.put(put); htable2.put(put);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1112")); put.addColumn(famName, qualifierName, ts + 5, Bytes.toBytes("v1112"));
htable2.put(put); htable2.put(put);
scan = new Scan(); scan = new Scan();