From 0ed78bf96b885fa4f7d7978ca2036f8c1c85db53 Mon Sep 17 00:00:00 2001
From: Socrates <suyiteng@selectdb.com>
Date: Wed, 4 Jun 2025 18:59:18 +0800
Subject: [PATCH] fix hudi scan

---
 .../trees/plans/logical/LogicalHudiScan.java        | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
index a0bf5805ada889..f35a3af805e898 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
@@ -48,6 +48,7 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
+import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
@@ -73,7 +74,7 @@ protected LogicalHudiScan(RelationId id, ExternalTable table, List<String> quali
             SelectedPartitions selectedPartitions, Optional<TableSample> tableSample,
             Optional<TableSnapshot> tableSnapshot,
             Optional<TableScanParams> scanParams, Optional<IncrementalRelation> incrementalRelation,
-            List<Slot> operativeSlots) {
+            Collection<Slot> operativeSlots) {
         super(id, table, qualifier, groupExpression, logicalProperties,
                 selectedPartitions, tableSample, tableSnapshot, operativeSlots);
         Objects.requireNonNull(scanParams, "scanParams should not null");
@@ -83,7 +84,7 @@ protected LogicalHudiScan(RelationId id, ExternalTable table, List<String> quali
     }
 
     public LogicalHudiScan(RelationId id, ExternalTable table, List<String> qualifier,
-            Optional<TableSample> tableSample, Optional<TableSnapshot> tableSnapshot, List<Slot> operativeSlots) {
+            Optional<TableSample> tableSample, Optional<TableSnapshot> tableSnapshot, Collection<Slot> operativeSlots) {
         this(id, table, qualifier, Optional.empty(), Optional.empty(),
                 ((HMSExternalTable) table).initHudiSelectedPartitions(tableSnapshot), tableSample, tableSnapshot,
                 Optional.empty(), Optional.empty(),
@@ -167,6 +168,14 @@ public <R, C> R accept(PlanVisitor<R, C> visitor, C context) {
         return visitor.visitLogicalHudiScan(this, context);
     }
 
+    @Override
+    public LogicalFileScan withOperativeSlots(Collection<Slot> operativeSlots) {
+        return new LogicalHudiScan(relationId, (ExternalTable) table, qualifier,
+                groupExpression, Optional.of(getLogicalProperties()),
+                selectedPartitions, tableSample, tableSnapshot, scanParams, incrementalRelation,
+                operativeSlots);
+    }
+
     /**
      * Set scan params for incremental read
      *