This is an automated email from the ASF dual-hosted git repository.
dlmarion pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push:
new da7b3b005e Fixed RecoveryIT timeout issue (#4271)
da7b3b005e is described below
commit da7b3b005e13276c202b4f337496f9ecf2c039e5
Author: Dave Marion <[email protected]>
AuthorDate: Thu Feb 15 16:33:07 2024 -0500
Fixed RecoveryIT timeout issue (#4271)
Test was waiting for 60s to confirm that recovery logs were sorted. However,
the default interval for checking if recovery logs needed to be sorted is
1m.
Increased the timeout in the test so that it would not fail.
---
test/src/main/java/org/apache/accumulo/test/RecoveryIT.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/test/src/main/java/org/apache/accumulo/test/RecoveryIT.java
b/test/src/main/java/org/apache/accumulo/test/RecoveryIT.java
index c8fb440eea..6da4cd9d77 100644
--- a/test/src/main/java/org/apache/accumulo/test/RecoveryIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/RecoveryIT.java
@@ -18,6 +18,7 @@
*/
package org.apache.accumulo.test;
+import static
org.apache.accumulo.core.util.compaction.ExternalCompactionUtil.getCompactorAddrs;
import static org.apache.accumulo.harness.AccumuloITBase.MINI_CLUSTER_ONLY;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
@@ -142,7 +143,10 @@ public class RecoveryIT extends AccumuloClusterHarness {
// Stop any running Compactors and ScanServers
control.stopAllServers(ServerType.COMPACTOR);
+ Wait.waitFor(() ->
getCompactorAddrs(getCluster().getServerContext()).size() == 0, 60_000);
+
control.stopAllServers(ServerType.SCAN_SERVER);
+ Wait.waitFor(() -> ((ClientContext) c).getScanServers().size() == 0,
60_000);
// Kill the TabletServer in resource group that is hosting the table
List<Process> procs = control.getTabletServers(RESOURCE_GROUP);
@@ -181,7 +185,7 @@ public class RecoveryIT extends AccumuloClusterHarness {
}
// Confirm sorting completed
- Wait.waitFor(() -> logSortingCompleted(c, tid) == true, 60_000);
+ Wait.waitFor(() -> logSortingCompleted(c, tid) == true, 120_000);
// Start the tablet servers so that the Manager
// can assign the table and so that recovery can be completed.
