You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2022/04/22 18:22:41 UTC
[druid] branch master updated: QueryScheduler: Log per-query message at DEBUG level. (#12467)
This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new b7621226d2 QueryScheduler: Log per-query message at DEBUG level. (#12467)
b7621226d2 is described below
commit b7621226d28493899c1331f7bf45469706c248c5
Author: Gian Merlino <gi...@imply.io>
AuthorDate: Fri Apr 22 11:22:34 2022 -0700
QueryScheduler: Log per-query message at DEBUG level. (#12467)
We generally want to avoid having any routine per-query messages at
INFO level, because they pollute logs.
---
server/src/main/java/org/apache/druid/server/QueryScheduler.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/druid/server/QueryScheduler.java b/server/src/main/java/org/apache/druid/server/QueryScheduler.java
index 7db628a331..cc306e95fe 100644
--- a/server/src/main/java/org/apache/druid/server/QueryScheduler.java
+++ b/server/src/main/java/org/apache/druid/server/QueryScheduler.java
@@ -159,7 +159,12 @@ public class QueryScheduler implements QueryWatcher
Optional<Integer> priority = prioritizationStrategy.computePriority(queryPlus, segments);
query = priority.map(query::withPriority).orElse(query);
Optional<String> lane = laningStrategy.computeLane(queryPlus.withQuery(query), segments);
- LOGGER.info("[%s] lane assigned to [%s] query with [%,d] priority", lane.orElse("default"), query.getType(), priority.orElse(Integer.valueOf(0)));
+ LOGGER.debug(
+ "[%s] lane assigned to [%s] query with [%,d] priority",
+ lane.orElse("default"),
+ query.getType(),
+ priority.orElse(0)
+ );
final ServiceMetricEvent.Builder builderUsr = ServiceMetricEvent.builder().setFeed("metrics")
.setDimension("lane", lane.orElse("default"))
.setDimension("dataSource", query.getDataSource().getTableNames())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org