This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 2b8a4418d06 branch-3.0: [fix](Outfile) Set `retryTime` to one while
executing `outfile` statement. #48095 (#48216)
2b8a4418d06 is described below
commit 2b8a4418d06572f5aaf9d71832e4676ff343961b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Feb 25 09:48:40 2025 +0800
branch-3.0: [fix](Outfile) Set `retryTime` to one while executing `outfile`
statement. #48095 (#48216)
Cherry-picked from #48095
Co-authored-by: Tiewei Fang <[email protected]>
---
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 56bc302b93b..346b1a9722c 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
@@ -567,6 +567,11 @@ public class StmtExecutor {
UUID uuid;
int retryTime = Config.max_query_retry_time;
retryTime = retryTime <= 0 ? 1 : retryTime + 1;
+ // 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 = 1; i <= retryTime; i++) {
try {
execute(queryId);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
