From 5c817e4eff875cd2092ed24a269c32afe70e8f33 Mon Sep 17 00:00:00 2001 From: BePPPower Date: Thu, 27 Feb 2025 14:31:12 +0800 Subject: [PATCH] fix 1 --- .../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 5af00a127e2ecc..5f3bf4c1b1e7ae 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 void finalizeQuery() { 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