diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumberSchool.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumberSchool.java index 4a8332137d4..447caa4a7e6 100644 --- a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumberSchool.java +++ b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumberSchool.java @@ -117,6 +117,12 @@ public class RealtimePlumberSchool implements PlumberSchool this.rejectionPolicyFactory = factory; } + @JsonProperty("maxPendingPersists") + public void setDefaultMaxPendingPersists(int maxPendingPersists) + { + this.maxPendingPersists = maxPendingPersists; + } + public void setEmitter(ServiceEmitter emitter) { this.emitter = emitter; @@ -152,11 +158,6 @@ public class RealtimePlumberSchool implements PlumberSchool this.queryExecutorService = executorService; } - public void setDefaultMaxPendingPersists(int maxPendingPersists) - { - this.maxPendingPersists = maxPendingPersists; - } - @Override public Plumber findPlumber(final Schema schema, final FireDepartmentMetrics metrics) {