Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix queuedSize not decrease in HttpLoadQueuePeon when load failed (#8596)

This commit is contained in:
Fangyuan Deng 2019-09-26 23:48:00 +08:00 committed by Himanshu
parent 9f1f5e115c
commit a280c5dc03
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/src/main/java/org/apache/druid/server/coordinator/HttpLoadQueuePeon.java
View File

@ -576,6 +576,13 @@ public class HttpLoadQueuePeon extends LoadQueuePeon
queuedSize.addAndGet(-getSegment().getSize()); queuedSize.addAndGet(-getSegment().getSize());
super.requestSucceeded(); super.requestSucceeded();
} }
@Override
public void requestFailed(String failureCause)
{
queuedSize.addAndGet(-getSegment().getSize());
super.requestFailed(failureCause);
}
} }
private class DropSegmentHolder extends SegmentHolder private class DropSegmentHolder extends SegmentHolder