(accumulo) branch main updated: avoids time out in BulkNewIT (#6303)

[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 e47e63de95 avoids time out in BulkNewIT (#6303)
e47e63de95 is described below

commit e47e63de95c292a942e4005bd00190293e8efe41
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Thu Apr 9 11:29:28 2026 -0400

    avoids time out in BulkNewIT (#6303)
    
    BulkNewIT.testConcurrentCompactions() timed out in scan because it the
    scan was waiting for tablets to have less files.  The test imports 1000
    files and then scans.  The scan can not run until compactions run. Gave
    the test more compactors to process the compactions faster.
    
    The test was running two test in a single test method.  This means both
    test had the timeout of a single test method.  Ran the two test
    separately so they would each have their own timeout.
---
 .../apache/accumulo/test/functional/BulkNewIT.java   | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java 
b/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
index d308404c91..1ba19ca08f 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
@@ -123,6 +123,8 @@ import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.ValueSource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -154,7 +156,7 @@ public class BulkNewIT extends SharedMiniClusterBase {
     @Override
     public void configureMiniCluster(MiniAccumuloConfigImpl cfg, Configuration 
conf) {
       cfg.setMemory(ServerType.TABLET_SERVER, 512, MemoryUnit.MEGABYTE);
-
+      cfg.getClusterServerConfiguration().setNumDefaultCompactors(4);
       // use raw local file system
       conf.set("fs.file.impl", RawLocalFileSystem.class.getName());
     }
@@ -993,15 +995,9 @@ public class BulkNewIT extends SharedMiniClusterBase {
     }
   }
 
-  @Test
-  public void testConcurrentCompactions() throws Exception {
-    // run test with bulk imports happening in parallel
-    testConcurrentCompactions(true);
-    // run the test with bulk imports happening serially
-    testConcurrentCompactions(false);
-  }
-
-  private void testConcurrentCompactions(boolean parallelBulkImports) throws 
Exception {
+  @ParameterizedTest
+  @ValueSource(booleans = {true, false})
+  public void testConcurrentCompactions(boolean parallelBulkImports) throws 
Exception {
     // Tests compactions running concurrently with bulk import to ensure that 
data is not bulk
     // imported twice. Doing a large number of bulk imports should naturally 
cause compactions to
     // happen. This test ensures that compactions running concurrently with 
bulk import does not
@@ -1087,6 +1083,10 @@ public class BulkNewIT extends SharedMiniClusterBase {
         // expect to see 10 tablets
         assertEquals(10, rowCounts.size());
       }
+
+      // since this is a parameterized test it will use the same tableName, so 
delete for the next
+      // parameterized iteration
+      c.tableOperations().delete(tableName);
     }
   }