This is an automated email from the ASF dual-hosted git repository.
morningman 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 2b010530801 [fix](Outfile) Set `retryTime` to one while executing
`outfile` statement. (#48095)
2b010530801 is described below
commit 2b01053080118f7cda7d8d3f1022e167de98491c
Author: Tiewei Fang <fangtie...@selectdb.com>
AuthorDate: Mon Feb 24 10:44:45 2025 +0800
[fix](Outfile) Set `retryTime` to one while executing `outfile` statement.
(#48095)
Problem Summary:
If the query is an `outfile` statement, we execute it only once to avoid
exporting redundant data.
---
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 53f34613de0..502f57cc43b 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
@@ -573,6 +573,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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
