[doris] 11/15: [fix](iceberg-v2) fix fe iceberg split, add regression case (#15299)

[morningman]

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 3c6f78e94543b1a8df7e50a2429ab4653ce767cf
Author: slothever <18522955+w...@users.noreply.github.com>
AuthorDate: Fri Dec 23 19:33:00 2022 +0800

    [fix](iceberg-v2) fix fe iceberg split, add regression case (#15299)
---
 .../main/java/org/apache/doris/planner/external/QueryScanProvider.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/QueryScanProvider.java
 
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/QueryScanProvider.java
index a2ce044bb7..a7453394f6 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/QueryScanProvider.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/QueryScanProvider.java
@@ -106,7 +106,7 @@ public abstract class QueryScanProvider implements 
FileScanProviderIf {
                 TFileRangeDesc rangeDesc = createFileRangeDesc(fileSplit, 
partitionValuesFromPath, pathPartitionKeys);
                 // external data lake table
                 if (split instanceof IcebergSplit) {
-                    IcebergScanProvider.setIcebergParams(rangeDesc, 
(IcebergSplit) inputSplit);
+                    IcebergScanProvider.setIcebergParams(rangeDesc, 
(IcebergSplit) split);
                 }
                 
curLocations.getScanRange().getExtScanRange().getFileScanRange().addToRanges(rangeDesc);
                 LOG.debug("assign to backend {} with table split: {} ({}, {}), 
location: {}",


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