This is an automated email from the ASF dual-hosted git repository.
cambyzju pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new e3b1916b11f fix query external table make BE crash (#34477)
e3b1916b11f is described below
commit e3b1916b11f2b6a758763ece89020fb50810ca0b
Author: camby <[email protected]>
AuthorDate: Thu May 9 10:28:47 2024 +0800
fix query external table make BE crash (#34477)
---
.../java/org/apache/doris/planner/external/ExternalFileScanNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/ExternalFileScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/ExternalFileScanNode.java
index 124acdb71ac..b89e5db4a66 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/ExternalFileScanNode.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/ExternalFileScanNode.java
@@ -339,7 +339,6 @@ public class ExternalFileScanNode extends ExternalScanNode {
ParamCreateContext context = contexts.get(i);
FileScanProviderIf scanProvider = scanProviders.get(i);
setDefaultValueExprs(scanProvider, context);
- setColumnPositionMappingForTextFile(scanProvider, context);
finalizeParamsForLoad(context, analyzer);
createScanRangeLocations(context, scanProvider);
this.inputSplitsNum += scanProvider.getInputSplitNum();
@@ -358,6 +357,7 @@ public class ExternalFileScanNode extends ExternalScanNode {
if (scanProvider instanceof IcebergScanProvider) {
((IcebergScanProvider)
scanProvider).updateRequiredSlots(context);
}
+ setColumnPositionMappingForTextFile(scanProvider, context);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
