diff --git a/server/src/main/java/io/druid/server/router/PriorityTieredBrokerSelectorStrategy.java b/server/src/main/java/io/druid/server/router/PriorityTieredBrokerSelectorStrategy.java index 8d52bcc81b9..d911aef7d35 100644 --- a/server/src/main/java/io/druid/server/router/PriorityTieredBrokerSelectorStrategy.java +++ b/server/src/main/java/io/druid/server/router/PriorityTieredBrokerSelectorStrategy.java @@ -38,7 +38,7 @@ public class PriorityTieredBrokerSelectorStrategy implements TieredBrokerSelecto @JsonProperty("maxPriority") Integer maxPriority ) { - this.minPriority = minPriority == null ? 1 : minPriority; + this.minPriority = minPriority == null ? 0 : minPriority; this.maxPriority = maxPriority == null ? 1 : maxPriority; } diff --git a/server/src/main/java/io/druid/server/router/TieredBrokerConfig.java b/server/src/main/java/io/druid/server/router/TieredBrokerConfig.java index c23a15dff61..7d8d5bb17b7 100644 --- a/server/src/main/java/io/druid/server/router/TieredBrokerConfig.java +++ b/server/src/main/java/io/druid/server/router/TieredBrokerConfig.java @@ -60,7 +60,7 @@ public class TieredBrokerConfig @NotNull private List strategies = Arrays.asList( new TimeBoundaryTieredBrokerSelectorStrategy(), - new PriorityTieredBrokerSelectorStrategy(1, 1) + new PriorityTieredBrokerSelectorStrategy(0, 1) ); // tier,