HBASE-22003 Fix flaky test TestVerifyReplication.testHBase14905

This commit is contained in:
Guanghao 2019-05-28 17:22:53 +08:00 committed by Guanghao Zhang
parent 8e9b504ffe
commit c51ec42a44
1 changed files with 6 additions and 5 deletions

View File

@ -252,11 +252,12 @@ public class TestVerifyReplication extends TestReplicationBase {
// normal Batch tests
byte[] qualifierName = Bytes.toBytes("f1");
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);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1001"));
put.addColumn(famName, qualifierName, ts + 2, Bytes.toBytes("v1001"));
htable1.put(put);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1112"));
put.addColumn(famName, qualifierName, ts + 3, Bytes.toBytes("v1112"));
htable1.put(put);
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);
put.addColumn(famName, qualifierName, Bytes.toBytes("v1112"));
put.addColumn(famName, qualifierName, ts + 5, Bytes.toBytes("v1112"));
htable2.put(put);
scan = new Scan();