This is an automated email from the ASF dual-hosted git repository.
abhishek 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 139156cf6b Reduce the spam in broker logs (#14368)
139156cf6b is described below
commit 139156cf6bd7cf28978b2aae6489ebfe6de020f7
Author: Abhishek Agarwal <[email protected]>
AuthorDate: Mon Jun 5 18:56:34 2023 +0530
Reduce the spam in broker logs (#14368)
---
.../druid/server/router/TieredBrokerHostSelector.java | 14 ++++++++------
1 file changed, 8 insertions(+), 6 deletions(-)
diff --git
a/services/src/main/java/org/apache/druid/server/router/TieredBrokerHostSelector.java
b/services/src/main/java/org/apache/druid/server/router/TieredBrokerHostSelector.java
index 8819f3ea4a..ea7b615187 100644
---
a/services/src/main/java/org/apache/druid/server/router/TieredBrokerHostSelector.java
+++
b/services/src/main/java/org/apache/druid/server/router/TieredBrokerHostSelector.java
@@ -235,12 +235,14 @@ public class TieredBrokerHostSelector
}
if (brokerServiceName == null) {
- log.error(
- "No brokerServiceName found for datasource[%s], intervals[%s]. Using
default[%s].",
- query.getDataSource(),
- query.getIntervals(),
- tierConfig.getDefaultBrokerServiceName()
- );
+ if (query.context().isDebug()) {
+ log.info(
+ "Using default broker service[%s] for query with datasource [%s]
and intervals[%s].",
+ tierConfig.getDefaultBrokerServiceName(),
+ query.getDataSource(),
+ query.getIntervals()
+ );
+ }
brokerServiceName = tierConfig.getDefaultBrokerServiceName();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
