This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 2b22990a7d1 branch-3.1: [fix](load) fix execute copy task fail #56551
(#56589)
2b22990a7d1 is described below
commit 2b22990a7d165a03c1a1fe9d260abe365ff9db3f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Sep 29 14:39:46 2025 +0800
branch-3.1: [fix](load) fix execute copy task fail #56551 (#56589)
Cherry-picked from #56551
Co-authored-by: hui lai <[email protected]>
---
.../main/java/org/apache/doris/cloud/load/CopyLoadPendingTask.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CopyLoadPendingTask.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CopyLoadPendingTask.java
index 0ab6a9ce907..d67938a305c 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CopyLoadPendingTask.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CopyLoadPendingTask.java
@@ -114,6 +114,11 @@ public class CopyLoadPendingTask extends
BrokerLoadPendingTask {
copyJob.isForceCopy());
}
}
+ if (!fileStatuses.isEmpty()) {
+
fileGroup.initDeferredFileFormatPropertiesIfNecessary(fileStatuses.stream()
+ .map(pair -> pair.first)
+ .collect(Collectors.toList()));
+ }
boolean isBinaryFileFormat = fileGroup.isBinaryFileFormat();
List<Pair<TBrokerFileStatus, ObjectFilePB>>
filteredFileStatuses = Lists.newArrayList();
for (Pair<TBrokerFileStatus, ObjectFilePB> pair :
fileStatuses) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
