database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[bugfix](feoom) add timeout to send be request to avoid too long to occupy memory (#33614)

Browse Source 
Co-authored-by: yiguolei <yiguolei@gmail.com>
This commit is contained in:
yiguolei
2024-04-13 17:50:22 +08:00
committed by yiguolei
parent 3decd850e2
commit e88bd3ca4c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java
View File

@ -85,7 +85,8 @@ public class BackendServiceClient {
public ListenableFuture<InternalService.PCancelPlanFragmentResult> cancelPlanFragmentAsync(
InternalService.PCancelPlanFragmentRequest request) {
return stub.cancelPlanFragment(request);
return stub.withDeadlineAfter(execPlanTimeout, TimeUnit.MILLISECONDS)
.cancelPlanFragment(request);
}
public Future<InternalService.PFetchDataResult> fetchDataAsync(InternalService.PFetchDataRequest request) {