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 bab78da1d5 Fix FateConcurrencyIT (#6268)
bab78da1d5 is described below
commit bab78da1d5d7e6a016350991e58abceac4f52848
Author: Dave Marion <[email protected]>
AuthorDate: Fri Mar 27 17:55:59 2026 -0400
Fix FateConcurrencyIT (#6268)
Test was broken as a result of incorrect changes in #6223
---
.../java/org/apache/accumulo/test/functional/FateConcurrencyIT.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/FateConcurrencyIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/FateConcurrencyIT.java
index 75faf0664f..f051ba8927 100644
---
a/test/src/main/java/org/apache/accumulo/test/functional/FateConcurrencyIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/functional/FateConcurrencyIT.java
@@ -28,7 +28,6 @@ import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
import java.time.Duration;
-import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@@ -47,7 +46,6 @@ import
org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.TableNotFoundException;
import org.apache.accumulo.core.clientImpl.ClientContext;
import org.apache.accumulo.core.clientImpl.Namespace;
-import org.apache.accumulo.core.compaction.thrift.TExternalCompaction;
import org.apache.accumulo.core.data.TableId;
import org.apache.accumulo.core.fate.AdminUtil;
import org.apache.accumulo.core.fate.Fate;
@@ -528,11 +526,10 @@ public class FateConcurrencyIT extends
AccumuloClusterHarness {
tables.stream().map(SlowOps::getTableName).filter(this::findFate).count());
Wait.waitFor(() -> {
- List<TExternalCompaction> compactions = new ArrayList<>();
AtomicInteger compactionCount = new AtomicInteger(0);
ExternalCompactionUtil.getCompactionsRunningOnCompactors((ClientContext)
client,
(t) -> compactionCount.incrementAndGet());
- return compactions.size() == compactionCount.get();
+ return tableCount == compactionCount.get();
});
tables.forEach(t -> {
