HBASE-27051 TestReplicationSource.testReplicationSourceInitializingMetric is flaky (#4448)
Signed-off-by: Wellington Chevreuil <wchevreuil@apache.org> Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
parent
a0f576cce4
commit
42a64f2a4d
|
@ -571,9 +571,9 @@ public class TestReplicationSource {
|
||||||
try {
|
try {
|
||||||
rs.startup();
|
rs.startup();
|
||||||
assertTrue(rs.isSourceActive());
|
assertTrue(rs.isSourceActive());
|
||||||
Waiter.waitFor(conf, 1000, () -> rs.getSourceMetrics().getSourceInitializing() == 1);
|
Waiter.waitFor(conf, 10000, () -> rs.getSourceMetrics().getSourceInitializing() == 1);
|
||||||
BadReplicationEndpoint.failing = false;
|
BadReplicationEndpoint.failing = false;
|
||||||
Waiter.waitFor(conf, 1000, () -> rs.getSourceMetrics().getSourceInitializing() == 0);
|
Waiter.waitFor(conf, 10000, () -> rs.getSourceMetrics().getSourceInitializing() == 0);
|
||||||
} finally {
|
} finally {
|
||||||
rs.terminate("Done");
|
rs.terminate("Done");
|
||||||
rss.stop("Done");
|
rss.stop("Done");
|
||||||
|
|
Loading…
Reference in New Issue