From 95bcfb8ad453a2a99ebbbfd21ee0b4e28cf83e99 Mon Sep 17 00:00:00 2001 From: Daniel Roberts ddanielr Date: Sat, 12 Sep 2026 01:27:59 +0000 Subject: [PATCH] Fix bulkIT failures 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. --- .../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 be4963c7631..f9749ab4346 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 @@ private SortedMap computeMappingFromFiles(FileSystem fs, T 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(); }