This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 381fe9e7977 [fix](cloud) Fix e-230 not retry in cloud (#56567)
381fe9e7977 is described below
commit 381fe9e7977b08a141485325f1d00b0374f1220e
Author: deardeng <[email protected]>
AuthorDate: Mon Sep 29 19:59:09 2025 +0800
[fix](cloud) Fix e-230 not retry in cloud (#56567)
---
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 6 +++++-
regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy | 1 +
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index c3958bee85d..d8d86ecf94e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -535,13 +535,17 @@ public class StmtExecutor {
try {
try {
executeByNereids(queryId);
- } catch (Exception e) {
+ } catch (NereidsException | ParseException e) {
if (context.getMinidump() != null &&
context.getMinidump().toString(4) != null) {
MinidumpUtils.saveMinidumpString(context.getMinidump(),
DebugUtil.printId(context.queryId()));
}
LOG.warn("Analyze failed. {}", context.getQueryIdentifier(),
e);
context.getState().setError(e.getMessage());
return;
+ } catch (Exception e) {
+ LOG.warn("Nereids execute failed. {}",
context.getQueryIdentifier(), e);
+ context.getState().setError(e.getMessage());
+ throw e;
}
} finally {
// revert Session Value
diff --git
a/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
b/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
index b815a28dc63..757bdd330d4 100644
--- a/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
+++ b/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
@@ -45,6 +45,7 @@ suite("test_retry_e-230", 'docker') {
options.connectToFollower = false
for (def j = 0; j < 2; j++) {
docker(options) {
+ sql """set enable_sql_cache=false"""
def tbl = 'test_retry_e_230_tbl'
def tbl1 = 'table_1'
def tbl2 = 'table_2'
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
