You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/12/22 08:55:57 UTC

[doris] 04/05: [fix](load) fix load failure caused by incorrect file format (#15222)

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git

commit fe643dde0f95a0dadbc864a96d86afb2a585198f
Author: luozenglin <37...@users.noreply.github.com>
AuthorDate: Thu Dec 22 09:38:37 2022 +0800

    [fix](load) fix load failure caused by incorrect file format (#15222)
    
    Issue Number: close #15221
---
 .../src/main/java/org/apache/doris/planner/external/FileGroupInfo.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java
index a33b4787d5..90ecbb9ef0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java
@@ -192,6 +192,7 @@ public class FileGroupInfo {
             long tmpBytes = curInstanceBytes + leftBytes;
             // header_type
             TFileFormatType formatType = formatType(context.fileGroup.getFileFormat(), fileStatus.path);
+            context.params.setFormatType(formatType);
             List<String> columnsFromPath = BrokerUtil.parseColumnsFromPath(fileStatus.path,
                     context.fileGroup.getColumnNamesFromPath());
             // Assign scan range locations only for broker load.


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org