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 d911aef7d35..8d52bcc81b9 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 ? 0 : minPriority; + this.minPriority = minPriority == null ? 1 : 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 283b9d23e7f..c23a15dff61 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(0, 0) + new PriorityTieredBrokerSelectorStrategy(1, 1) ); // tier,