(accumulo) branch 2.1 updated: Increase wait time in AdvertiseAndBindIT (#5777)

[dlmarion]

This is an automated email from the ASF dual-hosted git repository.

dlmarion pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/2.1 by this push:
     new 0564538f5a Increase wait time in AdvertiseAndBindIT (#5777)
0564538f5a is described below

commit 0564538f5a252da64d32c2e990b6c916ef6344ed
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Tue Aug 5 08:27:09 2025 -0400

    Increase wait time in AdvertiseAndBindIT (#5777)
    
    Doubled the wait time when calling Wait.waitFor to
    try and reduce flakiness of test on other test
    platforms. Wait.waitFor is timing out in some
    cases.
---
 .../accumulo/test/functional/AdvertiseAndBindIT.java     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/functional/AdvertiseAndBindIT.java
 
b/test/src/main/java/org/apache/accumulo/test/functional/AdvertiseAndBindIT.java
index 2c48718870..9529b3fc64 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/functional/AdvertiseAndBindIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/functional/AdvertiseAndBindIT.java
@@ -77,8 +77,8 @@ public class AdvertiseAndBindIT extends ConfigurableMacBase {
         new String[] {"-q", QUEUE1});
     getCluster().getClusterControl().start(ServerType.SCAN_SERVER, Map.of(), 1,
         new String[] {"-g", "DEFAULT"});
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty());
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty());
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty(), 60_000);
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty(), 60_000);
     try {
       Map<ServerType,HostAndPort> zkAddrs = 
getAdvertiseAddressFromZooKeeper(false);
       zkAddrs.values().forEach(hp -> 
assertTrue(hp.getHost().equals(localHostName)));
@@ -147,8 +147,8 @@ public class AdvertiseAndBindIT extends ConfigurableMacBase 
{
         new String[] {"-q", QUEUE1});
     getCluster().getClusterControl().start(ServerType.SCAN_SERVER, Map.of(), 1,
         new String[] {"-g", "DEFAULT"});
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty());
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty());
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty(), 60_000);
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty(), 60_000);
     try {
       Map<ServerType,HostAndPort> zkAddrs = 
getAdvertiseAddressFromZooKeeper(false);
       zkAddrs.values().forEach(hp -> 
assertTrue(hp.getHost().equals(localHostName)));
@@ -237,8 +237,8 @@ public class AdvertiseAndBindIT extends ConfigurableMacBase 
{
     sserverArgs.add("-g");
     sserverArgs.add("DEFAULT");
     control.start(ServerType.SCAN_SERVER, Map.of(), 1, sserverArgs.toArray(new 
String[] {}));
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty());
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty());
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty(), 60_000);
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty(), 60_000);
   }
 
   private void restartClusterWithProperties(Map<String,String> properties, 
boolean skipCoordinator)
@@ -260,8 +260,8 @@ public class AdvertiseAndBindIT extends ConfigurableMacBase 
{
     }
     control.start(ServerType.COMPACTOR, properties, 1, new String[] {"-q", 
QUEUE1});
     control.start(ServerType.SCAN_SERVER, properties, 1, new String[] {"-g", 
"DEFAULT"});
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty());
-    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty());
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getCompactors().isEmpty(), 60_000);
+    Wait.waitFor(() -> 
!getServerContext().instanceOperations().getScanServers().isEmpty(), 60_000);
   }
 
   private Map<ServerType,HostAndPort> getAdvertiseAddressFromZooKeeper(boolean 
skipCoordinator)