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 7216d9219c Increased wait when stopping Mini server processes (#6589)
7216d9219c is described below

commit 7216d9219cfc792e8afed78049b0d75babc0059b
Author: Dave Marion <[email protected]>
AuthorDate: Fri Oct 16 21:41:52 2026 +0000

    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.
---
 .../apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java | 6 +++---
 1 file changed, 3 insertions(+), 3 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 492c79d417..ba5ca1df6d 100644
--- 
a/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
+++ 
b/minicluster/src/main/java/org/apache/accumulo/miniclusterImpl/MiniAccumuloClusterControl.java
@@ -349,7 +349,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       case TABLET_SERVER:
         synchronized (tabletServerProcesses) {
           try {
-            cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, 
tabletServerProcesses, 30,
+            cluster.stopProcessesWithTimeout(ServerType.TABLET_SERVER, 
tabletServerProcesses, 60,
                 TimeUnit.SECONDS);
           } finally {
             tabletServerProcesses.clear();
@@ -372,7 +372,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       case SCAN_SERVER:
         synchronized (scanServerProcesses) {
           try {
-            cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, 
scanServerProcesses, 30,
+            cluster.stopProcessesWithTimeout(ServerType.SCAN_SERVER, 
scanServerProcesses, 60,
                 TimeUnit.SECONDS);
           } finally {
             scanServerProcesses.clear();
@@ -395,7 +395,7 @@ public class MiniAccumuloClusterControl implements 
ClusterControl {
       case COMPACTOR:
         synchronized (compactorProcesses) {
           try {
-            cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, 
compactorProcesses, 30,
+            cluster.stopProcessesWithTimeout(ServerType.COMPACTOR, 
compactorProcesses, 60,
                 TimeUnit.SECONDS);
           } finally {
             compactorProcesses.clear();

Reply via email to