virajjasani commented on a change in pull request #1761:
URL: https://github.com/apache/hbase/pull/1761#discussion_r429595334
##########
File path:
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatus.java
##########
@@ -120,6 +124,35 @@ public void testReplicationStatus() throws Exception {
assertEquals(PEER_ID2, rLoadSourceList.get(0).getPeerID());
}
+ @Test
+ public void testReplicationStatusSink() throws Exception {
+ try (Admin hbaseAdmin = UTIL2.getConnection().getAdmin()) {
+ ServerName server =
UTIL2.getHBaseCluster().getRegionServer(0).getServerName();
+ ReplicationLoadSink loadSink = getLatestSinkMetric(hbaseAdmin, server);
+ //First checks if status of timestamp of last applied op is same as RS
start, since no edits
+ //were replicated yet
+ assertEquals(loadSink.getTimestampStarted(),
loadSink.getTimestampsOfLastAppliedOp());
+ //now insert some rows on source, so that it gets delivered to target
+ insertRowsOnSource();
+ long wait = Waiter.waitFor(UTIL2.getConfiguration(),
+ 100000, new Waiter.Predicate<Exception>() {
Review comment:
Want to keep it 10s instead of 100s? :)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
