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

kturner 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 0d3c2230ca avoid creating thread pool metrics per batch writer (#5606)
0d3c2230ca is described below

commit 0d3c2230ca66752c63847f3c5bf6ed3f72a962d9
Author: Keith Turner <[email protected]>
AuthorDate: Mon Jun 2 10:19:07 2025 -0400

    avoid creating thread pool metrics per batch writer (#5606)
    
    Each batch writer created was creating a thread pool intrumented with
    metrics.  This would cause Meters to continually be added to the global
    registry which could eventually cause memory problems.  Disabled metrics
    instrumentation on these thread pools.
---
 .../org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java
 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java
index cda943d5c5..e2f92acbea 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java
@@ -212,7 +212,7 @@ public class TabletServerBatchWriter implements 
AutoCloseable {
   public TabletServerBatchWriter(ClientContext context, BatchWriterConfig 
config) {
     this.context = context;
     this.executor = context.threadPools().createScheduledExecutorService(2,
-        "BatchWriterThreads-" + numWritersCreated.incrementAndGet(), true);
+        "BatchWriterThreads-" + numWritersCreated.incrementAndGet(), false);
     this.failedMutations = new FailedMutations();
     this.maxMem = config.getMaxMemory();
     this.maxLatency = config.getMaxLatency(MILLISECONDS) <= 0 ? Long.MAX_VALUE

Reply via email to