You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kr...@apache.org on 2024/12/16 15:49:19 UTC
(accumulo) branch main updated (632dbc2ed0 -> e73a27d575)
This is an automated email from the ASF dual-hosted git repository.
krathbun pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
from 632dbc2ed0 limits memory and cpu used by compaction reservation request (#5185)
add 7b8b21335e Adds new accumulo command (#5073)
add 79d972f83b Fix Fate pool watcher bug (#5171)
add 91600dd231 Merge remote-tracking branch 'upstream/2.1' into 3.1
new e73a27d575 Merge remote-tracking branch 'upstream/3.1'
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/accumulo/core/fate/Fate.java | 2 +-
.../server/conf/CheckAccumuloProperties.java | 66 ++++++++++++++++++++++
2 files changed, 67 insertions(+), 1 deletion(-)
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/conf/CheckAccumuloProperties.java
(accumulo) 01/01: Merge remote-tracking branch 'upstream/3.1'
Posted by kr...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
krathbun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit e73a27d575276e04bf1eb9717a9704b6f28d55bc
Merge: 632dbc2ed0 91600dd231
Author: Kevin Rathbun <ke...@gmail.com>
AuthorDate: Mon Dec 16 10:46:54 2024 -0500
Merge remote-tracking branch 'upstream/3.1'
.../java/org/apache/accumulo/core/fate/Fate.java | 2 +-
.../server/conf/CheckAccumuloProperties.java | 66 ++++++++++++++++++++++
2 files changed, 67 insertions(+), 1 deletion(-)
diff --cc core/src/main/java/org/apache/accumulo/core/fate/Fate.java
index 0be6b50eaa,a1f5e26088..a45cb3a405
--- a/core/src/main/java/org/apache/accumulo/core/fate/Fate.java
+++ b/core/src/main/java/org/apache/accumulo/core/fate/Fate.java
@@@ -355,8 -243,7 +355,8 @@@ public class Fate<T>
// resize the pool if the property changed
ThreadPools.resizePool(pool, conf, Property.MANAGER_FATE_THREADPOOL_SIZE);
// If the pool grew, then ensure that there is a TransactionRunner for each thread
- int needed = conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE) - pool.getActiveCount();
+ final int configured = conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE);
- final int needed = configured - pool.getQueue().size();
++ final int needed = configured - pool.getActiveCount();
if (needed > 0) {
for (int i = 0; i < needed; i++) {
try {