This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 5a5e433560c branch-2.1:[fix](Outfile) Set retryTime to one while
executing outfile statement. (#48423)
5a5e433560c is described below
commit 5a5e433560c6a736a0dace2054d6e75568fa37d9
Author: Tiewei Fang <ftw2...@163.com>
AuthorDate: Fri Feb 28 13:57:10 2025 +0800
branch-2.1:[fix](Outfile) Set retryTime to one while executing outfile
statement. (#48423)
Problem Summary:
picked from #48095
---
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 5 +++++
1 file changed, 5 insertions(+)
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 5af00a127e2..5f3bf4c1b1e 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
@@ -835,6 +835,11 @@ public class StmtExecutor {
private void handleQueryWithRetry(TUniqueId queryId) throws Exception {
// queue query here
int retryTime = Config.max_query_retry_time;
+ // If the query is an `outfile` statement,
+ // we execute it only once to avoid exporting redundant data.
+ if (parsedStmt instanceof Queriable) {
+ retryTime = ((Queriable) parsedStmt).hasOutFileClause() ? 1 :
retryTime;
+ }
for (int i = 0; i < retryTime; i++) {
try {
// reset query id for each retry
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
