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

edcoleman 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 7778203  Fix #2053 Fix typo -in TabletServerResourceManager
7778203 is described below

commit 77782030dbe674accf2c7d221b193e9593ae31b0
Author: Himanshu <addyjeri...@gmail.com>
AuthorDate: Sun May 2 23:04:46 2021 +0530

    Fix #2053 Fix typo -in TabletServerResourceManager
    
    Rename summaryParitionPool to summaryPartitionPool
---
 .../org/apache/accumulo/tserver/TabletServerResourceManager.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
index 941a654..efd3c67 100644
--- 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
+++ 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
@@ -98,7 +98,7 @@ public class TabletServerResourceManager {
   private final ExecutorService assignmentPool;
   private final ExecutorService assignMetaDataPool;
   private final ExecutorService summaryRetrievalPool;
-  private final ExecutorService summaryParitionPool;
+  private final ExecutorService summaryPartitionPool;
   private final ExecutorService summaryRemotePool;
 
   private final Map<String,ExecutorService> scanExecutors;
@@ -363,11 +363,11 @@ public class TabletServerResourceManager {
         () -> 
context.getConfiguration().getCount(Property.TSERV_SUMMARY_REMOTE_THREADS),
         "summary remote", (ThreadPoolExecutor) summaryRemotePool);
 
-    summaryParitionPool =
+    summaryPartitionPool =
         ThreadPools.createExecutorService(acuConf, 
Property.TSERV_SUMMARY_PARTITION_THREADS);
     modifyThreadPoolSizesAtRuntime(
         () -> 
context.getConfiguration().getCount(Property.TSERV_SUMMARY_PARTITION_THREADS),
-        "summary partition", (ThreadPoolExecutor) summaryParitionPool);
+        "summary partition", (ThreadPoolExecutor) summaryPartitionPool);
 
     Collection<ScanExecutorConfig> scanExecCfg = acuConf.getScanExecutors();
     Map<String,Queue<Runnable>> scanExecQueues = new HashMap<>();
@@ -859,7 +859,7 @@ public class TabletServerResourceManager {
   }
 
   public ExecutorService getSummaryPartitionExecutor() {
-    return summaryParitionPool;
+    return summaryPartitionPool;
   }
 
   public ExecutorService getSummaryRemoteExecutor() {

Reply via email to