diff --git a/server/src/main/java/io/druid/server/router/TieredBrokerHostSelector.java b/server/src/main/java/io/druid/server/router/TieredBrokerHostSelector.java index cc625cdc5a3b858b6e5ac68004afb467be67ed9f..9e5db5084eb13eb5eec98879b00afc50b447c097 100644 --- a/server/src/main/java/io/druid/server/router/TieredBrokerHostSelector.java +++ b/server/src/main/java/io/druid/server/router/TieredBrokerHostSelector.java @@ -170,23 +170,23 @@ public class TieredBrokerHostSelector implements HostSelector } if (brokerServiceName == null) { - log.makeAlert( + log.error( "WTF?! No brokerServiceName found for datasource[%s], intervals[%s]. Using default[%s].", query.getDataSource(), query.getIntervals(), tierConfig.getDefaultBrokerServiceName() - ).emit(); + ); brokerServiceName = tierConfig.getDefaultBrokerServiceName(); } ServerDiscoverySelector retVal = selectorMap.get(brokerServiceName); if (retVal == null) { - log.makeAlert( + log.error( "WTF?! No selector found for brokerServiceName[%s]. Using default selector for[%s]", brokerServiceName, tierConfig.getDefaultBrokerServiceName() - ).emit(); + ); retVal = selectorMap.get(tierConfig.getDefaultBrokerServiceName()); }