This is an automated email from the ASF dual-hosted git repository.
eldenmoon pushed a commit to branch timeout-future
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 963a5158933a723a22dc78122509ef1b035939ca
Author: eldenmoon <15605149...@163.com>
AuthorDate: Thu Jul 6 16:24:44 2023 +0800
[Bug](point query) cancel future when meet timeout in PointQueryExec
---
fe/fe-core/src/main/java/org/apache/doris/qe/PointQueryExec.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/PointQueryExec.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/PointQueryExec.java
index e62e849be0..4bcbb61c28 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/PointQueryExec.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/PointQueryExec.java
@@ -201,6 +201,11 @@ public class PointQueryExec {
status.setStatus(Status.CANCELLED);
return null;
}
+ } catch (TimeoutException e) {
+ futureResponse.cancel(true);
+ LOG.warn("fetch result timeout {}",
backend.getBrpcAdress());
+ status.setStatus("query timeout");
+ return null;
}
}
} catch (RpcException e) {
@@ -218,10 +223,6 @@ public class PointQueryExec {
SimpleScheduler.addToBlacklist(backend.getId(),
e.getMessage());
}
return null;
- } catch (TimeoutException e) {
- LOG.warn("fetch result timeout {}", backend.getBrpcAdress());
- status.setStatus("query timeout");
- return null;
}
TStatusCode code =
TStatusCode.findByValue(pResult.getStatus().getStatusCode());
if (code != TStatusCode.OK) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
