diff --git a/server/src/main/java/org/apache/druid/server/coordinator/HttpLoadQueuePeon.java b/server/src/main/java/org/apache/druid/server/coordinator/HttpLoadQueuePeon.java index cbb0c265f73..4652659a35d 100644 --- a/server/src/main/java/org/apache/druid/server/coordinator/HttpLoadQueuePeon.java +++ b/server/src/main/java/org/apache/druid/server/coordinator/HttpLoadQueuePeon.java @@ -576,6 +576,13 @@ public class HttpLoadQueuePeon extends LoadQueuePeon queuedSize.addAndGet(-getSegment().getSize()); super.requestSucceeded(); } + + @Override + public void requestFailed(String failureCause) + { + queuedSize.addAndGet(-getSegment().getSize()); + super.requestFailed(failureCause); + } } private class DropSegmentHolder extends SegmentHolder