(accumulo) branch main updated: Increased wait when stopping Mini server processes (#6589)

[dlmarion]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 07475ac8d4 Increased wait when stopping Mini server processes (#6589)
07475ac8d4 is described below

commit 07475ac8d4d71761eb64d5a0b430f703a52d765c
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Thu Oct 15 11:30:20 2026 -0400

    Increased wait when stopping Mini server processes (#6589)
    
    A change was made in #6575 that modified the logic
    that stops the Mini processes from waiting up to
    30s per process to waiting up to 30s for all
    processes of a similar type. Seeing some IT
    failures because not all of the processes are
    stopped when the IT checks for that condition.
    This change doubles the amount of time that
    we will wait for all processes to stop, from
    30s to 60s in an attempt to resolve the failures.
---
 .../miniclusterImpl/MiniAccumuloClusterControl.java        | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
 
b/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
index deb8794740..2495a88688 100644
--- 
a/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
+++ 
b/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
@@ -291,7 +291,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       if (group == null) {
         return;
       }
-      cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, group, 30, 
TimeUnit.SECONDS);
+      cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, group, 60, 
TimeUnit.SECONDS);
       compactorProcesses.remove(compactorResourceGroup);
     }
   }
@@ -302,7 +302,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       if (group == null) {
         return;
       }
-      cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, group, 30, 
TimeUnit.SECONDS);
+      cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, group, 60, 
TimeUnit.SECONDS);
       scanServerProcesses.remove(sserverResourceGroup);
     }
   }
@@ -313,7 +313,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       if (group == null) {
         return;
       }
-      cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, group, 30, 
TimeUnit.SECONDS);
+      cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, group, 60, 
TimeUnit.SECONDS);
       tabletServerProcesses.remove(tserverResourceGroup);
     }
   }
@@ -324,7 +324,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       case MANAGER:
         synchronized (managerProcesses) {
           try {
-            cluster.stopProcessesWithTimeout(ServerType.MANAGER, 
managerProcesses, 30,
+            cluster.stopProcessesWithTimeout(ServerType.MANAGER, 
managerProcesses, 60,
                 TimeUnit.SECONDS);
             try {
               
System.setProperty(SiteConfiguration.ACCUMULO_PROPERTIES_PROPERTY,
@@ -371,7 +371,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
           try {
             final List<Process> procs = new ArrayList<>();
             tabletServerProcesses.values().forEach(procs::addAll);
-            cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, procs, 
30, TimeUnit.SECONDS);
+            cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, procs, 
60, TimeUnit.SECONDS);
           } finally {
             tabletServerProcesses.clear();
           }
@@ -395,7 +395,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
           try {
             final List<Process> procs = new ArrayList<>();
             scanServerProcesses.values().forEach(procs::addAll);
-            cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, procs, 
30, TimeUnit.SECONDS);
+            cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, procs, 
60, TimeUnit.SECONDS);
           } finally {
             scanServerProcesses.clear();
           }
@@ -406,7 +406,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
           try {
             final List<Process> procs = new ArrayList<>();
             compactorProcesses.values().forEach(procs::addAll);
-            cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, procs, 30, 
TimeUnit.SECONDS);
+            cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, procs, 60, 
TimeUnit.SECONDS);
           } finally {
             compactorProcesses.clear();
           }