This is an automated email from the ASF dual-hosted git repository.
kturner 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 5cf9906e8a Verifies some compactors properties can be set in zookeeper
(#6206)
5cf9906e8a is described below
commit 5cf9906e8ae5aad5838ef6cb356d43ea186241fa
Author: Keith Turner <[email protected]>
AuthorDate: Mon Mar 16 14:09:24 2026 -0700
Verifies some compactors properties can be set in zookeeper (#6206)
---
.../apache/accumulo/test/conf/ResourceGroupConfigIT.java | 14 +++++++++++---
1 file changed, 11 insertions(+), 3 deletions(-)
diff --git
a/test/src/main/java/org/apache/accumulo/test/conf/ResourceGroupConfigIT.java
b/test/src/main/java/org/apache/accumulo/test/conf/ResourceGroupConfigIT.java
index 513e78a4b8..4448c0dfed 100644
---
a/test/src/main/java/org/apache/accumulo/test/conf/ResourceGroupConfigIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/conf/ResourceGroupConfigIT.java
@@ -399,15 +399,23 @@ public class ResourceGroupConfigIT extends
SharedMiniClusterBase {
Map<String,String> firstProps = Map.of(
Property.COMPACTION_WARN_TIME.getKey(), "1m",
Property.SSERV_WAL_SORT_MAX_CONCURRENT.getKey(), "4",
- Property.TSERV_ASSIGNMENT_MAXCONCURRENT.getKey(), "10");
+ Property.TSERV_ASSIGNMENT_MAXCONCURRENT.getKey(), "10",
+ Property.COMPACTOR_MIN_JOB_WAIT_TIME.getKey(), "1s",
+ Property.COMPACTOR_MAX_JOB_WAIT_TIME.getKey(), "11s",
+ Property.COMPACTOR_FAILURE_BACKOFF_INTERVAL.getKey(), "11s");
Map<String,String> secondProps = Map.of(
Property.SSERV_WAL_SORT_MAX_CONCURRENT.getKey(), "5",
- Property.TSERV_ASSIGNMENT_MAXCONCURRENT.getKey(), "10");
+ Property.TSERV_ASSIGNMENT_MAXCONCURRENT.getKey(), "10",
+ Property.COMPACTOR_MAX_JOB_WAIT_TIME.getKey(), "10s",
+ Property.COMPACTOR_FAILURE_BACKOFF_RESET.getKey(), "5m");
Map<String,String> thirdProps = Map.of(
Property.COMPACTION_WARN_TIME.getKey(), "1m",
- Property.SSERV_WAL_SORT_MAX_CONCURRENT.getKey(), "6");
+ Property.SSERV_WAL_SORT_MAX_CONCURRENT.getKey(), "6",
+ Property.COMPACTOR_FAILURE_BACKOFF_RESET.getKey(), "4m",
+ Property.COMPACTOR_FAILURE_BACKOFF_THRESHOLD.getKey(), "4",
+ Property.COMPACTOR_FAILURE_TERMINATION_THRESHOLD.getKey(), "20");
// @formatter:off
try (var client = Accumulo.newClient().from(getClientProps()).build()) {