This is an automated email from the ASF dual-hosted git repository.
liulijia pushed a commit to branch fix-proxy-prepare
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/fix-proxy-prepare by this push:
new f617b58d1ab small fix
f617b58d1ab is described below
commit f617b58d1abaa22ebb3d9182ffa9091e360e79de
Author: liutang123 <[email protected]>
AuthorDate: Thu Mar 6 11:29:30 2025 +0800
small fix
---
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
index c8eb634efaf..11961ec3f3f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -666,9 +666,8 @@ public abstract class ConnectProcessor {
preparedStatementContext,
ByteBuffer.wrap(request.getPrepareExecuteBuffer()).order(ByteOrder.LITTLE_ENDIAN),
queryId);
} else {
- executor.execute(queryId);
+ executor.queryRetry(queryId);
}
- executor.queryRetry(queryId);
} catch (IOException e) {
// Client failed.
LOG.warn("Process one query failed because IOException: ", e);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
