(accumulo) branch main updated: fixes occasional failures in MultipleManagerStartupWaitIT (#6290)

[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 8e09a1ca45 fixes occasional failures in MultipleManagerStartupWaitIT 
(#6290)
8e09a1ca45 is described below

commit 8e09a1ca452156b098db7eb5a962bf47b0dc5c52
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Thu Apr 2 12:25:22 2026 -0700

    fixes occasional failures in MultipleManagerStartupWaitIT (#6290)
---
 .../org/apache/accumulo/test/MultipleManagerStartupWaitIT.java     | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/MultipleManagerStartupWaitIT.java 
b/test/src/main/java/org/apache/accumulo/test/MultipleManagerStartupWaitIT.java
index cb6aa92606..cef6ac0535 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/MultipleManagerStartupWaitIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/MultipleManagerStartupWaitIT.java
@@ -19,7 +19,6 @@
 package org.apache.accumulo.test;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
@@ -102,9 +101,13 @@ public class MultipleManagerStartupWaitIT extends 
ConfigurableMacBase {
     Set<String> managerHosts = new HashSet<>();
     managers.forEach(m -> managerHosts.add(m.getServer()));
 
+    // There is a time period where the primary manager has the lock but has 
not yet set the address
+    // on the lock, when the address is not set an empty set would be 
returned. So this waits for
+    // the address to be set.
+    Wait.waitFor(() -> !getCluster().getServerContext().instanceOperations()
+        .getServers(ServerId.Type.MANAGER).isEmpty());
     Set<ServerId> primary =
         
getCluster().getServerContext().instanceOperations().getServers(ServerId.Type.MANAGER);
-    assertNotNull(primary);
     assertEquals(1, primary.size());
     
assertTrue(managerHosts.contains(primary.iterator().next().toHostPortString()));
     assertNull(startError.get());