(accumulo) branch 2.1 updated: Fix numFiles check in GracefulShutdownIT (#6472)

[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 21139f63c6 Fix numFiles check in GracefulShutdownIT (#6472)
21139f63c6 is described below

commit 21139f63c6a92368befd22a3bacc71d0a04ea19c
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Thu Jul 9 14:43:33 2026 -0400

    Fix numFiles check in GracefulShutdownIT (#6472)
    
    GracefulShutdownIT was periodically failing when checking if
    the number of files in the table was lower than before a
    compaction occurred. This check was happening too quickly
    and not allowing for the coordinator to notify the tablet
    server to commit the compaction. Changed the logic to wait
    for the condition instead of checking it once.
---
 .../java/org/apache/accumulo/test/functional/GracefulShutdownIT.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java
 
b/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java
index cbdb01b2f2..e98a3a1d1b 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java
@@ -232,9 +232,8 @@ public class GracefulShutdownIT extends 
SharedMiniClusterBase {
         control.refreshProcesses(ServerType.COMPACTOR);
         return control.getProcesses(ServerType.COMPACTOR).isEmpty();
       });
-      final long numFiles3 = getNumFilesForTable(ctx, tid);
-      assertTrue(numFiles3 < numFiles2);
-      assertEquals(1, numFiles3);
+      Wait.waitFor(() -> getNumFilesForTable(ctx, tid) < numFiles2);
+      assertEquals(1, getNumFilesForTable(ctx, tid));
 
       getCluster().getConfig().setNumScanServers(1);
       control.startScanServer(ScanServer.class, 1, GROUP_NAME);