(accumulo) branch 2.1 updated: Fix inverted condition in ExternalCompactionProgressIT wait for compaction start (#6066)

[domgarguilo]

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

domgarguilo 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 64741921c5 Fix inverted condition in ExternalCompactionProgressIT wait 
for compaction start (#6066)
64741921c5 is described below

commit 64741921c5f5a520dc99ae5d630753585f356662
Author: ConfX <114765570+teamco...@users.noreply.github.com>
AuthorDate: Wed Jan 21 12:46:57 2026 -0600

    Fix inverted condition in ExternalCompactionProgressIT wait for compaction 
start (#6066)
    
    * fix inverted condition
    
    * Apply code formatting
---
 .../accumulo/test/compaction/ExternalCompactionProgressIT.java | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java
 
b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java
index 6f70584e9f..42477aad9c 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java
@@ -141,13 +141,21 @@ public class ExternalCompactionProgressIT extends 
AccumuloClusterHarness {
           EnumSet.of(IteratorUtil.IteratorScope.majc));
 
       log.info("Compacting table");
+
+      // Verify no compactions are running before we start (catch any leftover 
state from other
+      // tests)
+      Map<String,TExternalCompaction> initialCompactions =
+          
getRunningCompactions(getCluster().getServerContext()).getCompactions();
+      assertTrue(initialCompactions == null || initialCompactions.isEmpty(),
+          "Expected no running compactions before starting the test");
+
       compact(client, table, 2, QUEUE1, false);
 
       // Wait until the compaction starts
       Wait.waitFor(() -> {
         Map<String,TExternalCompaction> compactions =
             
getRunningCompactions(getCluster().getServerContext()).getCompactions();
-        return compactions == null || compactions.isEmpty();
+        return compactions != null && !compactions.isEmpty();
       }, 30_000, 100, "Compaction did not start within the expected time");
 
       // start a timer after the compaction starts