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(); }