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 826224e5d5 reduces log level for some chatty logs (#5082)
826224e5d5 is described below
commit 826224e5d55917004ce899455f44bff775a48b68
Author: Keith Turner <[email protected]>
AuthorDate: Wed Mar 12 17:10:27 2025 -0400
reduces log level for some chatty logs (#5082)
---
.../java/org/apache/accumulo/server/conf/CheckCompactionConfig.java | 3 ++-
.../accumulo/manager/compaction/coordinator/QueueMetrics.java | 6 +++---
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/conf/CheckCompactionConfig.java
b/server/base/src/main/java/org/apache/accumulo/server/conf/CheckCompactionConfig.java
index 2f9d9ec7c2..3e3111f7aa 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/conf/CheckCompactionConfig.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/conf/CheckCompactionConfig.java
@@ -106,7 +106,8 @@ public class CheckCompactionConfig implements
KeywordExecutable {
Set<String> defaultService = Set.of(DEFAULT_COMPACTION_SERVICE_NAME);
if (servicesConfig.getPlanners().keySet().equals(defaultService)) {
- log.warn("Only the default compaction service was created - {}",
defaultService);
+ log.atLevel(level).log("Only the default compaction service was created
- {}",
+ defaultService);
return;
}
diff --git
a/server/manager/src/main/java/org/apache/accumulo/manager/compaction/coordinator/QueueMetrics.java
b/server/manager/src/main/java/org/apache/accumulo/manager/compaction/coordinator/QueueMetrics.java
index 601714ba11..c4a58de005 100644
---
a/server/manager/src/main/java/org/apache/accumulo/manager/compaction/coordinator/QueueMetrics.java
+++
b/server/manager/src/main/java/org/apache/accumulo/manager/compaction/coordinator/QueueMetrics.java
@@ -169,15 +169,15 @@ public class QueueMetrics implements MetricsProducer {
CompactionJobQueues::getQueueCount)
.description(COMPACTOR_JOB_PRIORITY_QUEUES.getDescription()).register(localRegistry);
}
- LOG.debug("update - cjq queues: {}", compactionJobQueues.getQueueIds());
+ LOG.trace("update - cjq queues: {}", compactionJobQueues.getQueueIds());
Set<CompactorGroupId> definedQueues = compactionJobQueues.getQueueIds();
- LOG.debug("update - defined queues: {}", definedQueues);
+ LOG.trace("update - defined queues: {}", definedQueues);
// Copy the keySet into a new Set so that changes to perQueueMetrics
// don't affect the collection
Set<CompactorGroupId> queuesWithMetrics = new
HashSet<>(perQueueMetrics.keySet());
- LOG.debug("update - queues with metrics: {}", queuesWithMetrics);
+ LOG.trace("update - queues with metrics: {}", queuesWithMetrics);
SetView<CompactorGroupId> queuesWithoutMetrics =
Sets.difference(definedQueues, queuesWithMetrics);