(accumulo) branch 2.1 updated: Fix bulkIT failures (#6535)

[ddanielr]

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

ddanielr 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 e60b0f92b6 Fix bulkIT failures (#6535)
e60b0f92b6 is described below

commit e60b0f92b61e222de9a1edaafc74b4dfba629c37
Author: Daniel Roberts <ddani...@gmail.com>
AuthorDate: Tue Sep 15 13:08:12 2026 -0400

    Fix bulkIT failures (#6535)
    
    ClientProperties do not return the default value if they are not set.
    Adds back in a default value if the prop is null or set to an empty
    string.
---
 .../java/org/apache/accumulo/core/clientImpl/bulk/BulkImport.java  | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/bulk/BulkImport.java 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/bulk/BulkImport.java
index be4963c763..f9749ab434 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/bulk/BulkImport.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/bulk/BulkImport.java
@@ -507,10 +507,13 @@ public class BulkImport implements 
ImportDestinationArguments, ImportMappingOpti
       executor = service = 
context.threadPools().getPoolBuilder(BULK_IMPORT_CLIENT_LOAD_POOL)
           .numCoreThreads(numThreads).enableThreadPoolMetrics().build();
     } else {
+      String threads = 
context.getConfiguration().get(BULK_LOAD_THREADS.getKey());
+      if (threads == null || threads.isBlank()) {
+        threads = BULK_LOAD_THREADS.getDefaultValue();
+      }
       executor =
           service = 
context.threadPools().getPoolBuilder(BULK_IMPORT_CLIENT_BULK_THREADS_POOL)
-              .numCoreThreads(ConfigurationTypeHelper
-                  
.getNumThreads(context.getConfiguration().get(BULK_LOAD_THREADS.getKey())))
+              .numCoreThreads(ConfigurationTypeHelper.getNumThreads(threads))
               .enableThreadPoolMetrics().build();
     }