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() {