This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new c0968834f08 [bugfix](feoom) add timeout to send be request to avoid
too long to occupy memory (#33614)
c0968834f08 is described below
commit c0968834f08e847e9d10e9ed5fe26ce80c511b8d
Author: yiguolei <[email protected]>
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 <[email protected]>
---
.../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 4027cf6d951..8a74e45edc5 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: [email protected]
For additional commands, e-mail: [email protected]
