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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to