(accumulo) branch main updated: fixes flaky fate cancel command IT (#6287)

[kturner]

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

kturner 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 1e8862b04f fixes flaky fate cancel command IT (#6287)
1e8862b04f is described below

commit 1e8862b04f573c4d5a96a68d2c510ea6ff010d3d
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Wed Apr 1 19:41:42 2026 -0400

    fixes flaky fate cancel command IT (#6287)
---
 .../java/org/apache/accumulo/test/fate/FateOpsCommandsITBase.java  | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/fate/FateOpsCommandsITBase.java 
b/test/src/main/java/org/apache/accumulo/test/fate/FateOpsCommandsITBase.java
index 280efe6312..15b4798bb0 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/fate/FateOpsCommandsITBase.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/fate/FateOpsCommandsITBase.java
@@ -584,9 +584,12 @@ public abstract class FateOpsCommandsITBase extends 
SharedMiniClusterBase
 
       assertTrue(result
           .contains("transaction " + fateId1.canonical() + " was cancelled or 
already completed"));
+      var expected = Map.of(fateId1.canonical(), "FAILED", 
fateId2.canonical(), "NEW");
+      // The fate operation may temporarily be in the FAILED_IN_PROGRESS 
state, wait for this to
+      // pass
+      Wait.waitFor(() -> expected.equals(getFateIdsFromSummary()));
       fateIdsFromSummary = getFateIdsFromSummary();
-      assertEquals(Map.of(fateId1.canonical(), "FAILED", fateId2.canonical(), 
"NEW"),
-          fateIdsFromSummary);
+      assertEquals(expected, fateIdsFromSummary);
     } finally {
       fate.shutdown(1, TimeUnit.MINUTES);
     }