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

Reply via email to