This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 3aa36042f9b8a21e938c78081593aac67a50480b
Author: yiguolei <676222...@qq.com>
AuthorDate: Sat Apr 13 17:50:22 2024 +0800
[bugfix](feoom) add timeout to send be request to avoid too long to occupy
memory (#33614)
Co-authored-by: yiguolei <yiguo...@gmail.com>
---
.../src/main/java/org/apache/doris/rpc/BackendServiceClient.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java
b/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java
index 3f4bb846767..d7fb04c526d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java
@@ -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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
