HBASE-27051 TestReplicationSource.testReplicationSourceInitializingMe…

…tric is flaky (#4448) Signed-off-by: Wellington Chevreuil <[email protected]> Signed-off-by: Viraj Jasani <[email protected]>
apache · Jun 22, 2022 · cd2a7ff · cd2a7ff
1 parent 230e0a2
commit cd2a7ff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java b/...src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java
@@ -571,9 +571,9 @@ public void testReplicationSourceInitializingMetric() throws IOException {
     try {
       rs.startup();
       assertTrue(rs.isSourceActive());
-      Waiter.waitFor(conf, 1000, () -> rs.getSourceMetrics().getSourceInitializing() == 1);
+      Waiter.waitFor(conf, 10000, () -> rs.getSourceMetrics().getSourceInitializing() == 1);
       BadReplicationEndpoint.failing = false;
-      Waiter.waitFor(conf, 1000, () -> rs.getSourceMetrics().getSourceInitializing() == 0);
+      Waiter.waitFor(conf, 10000, () -> rs.getSourceMetrics().getSourceInitializing() == 0);
     } finally {
       rs.terminate("Done");
       rss.stop("Done");