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 quali SelectedPartitions selectedPartitions, Optional tableSample, Optional tableSnapshot, Optional scanParams, Optional incrementalRelation, - List operativeSlots) { + Collection 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 quali } public LogicalHudiScan(RelationId id, ExternalTable table, List qualifier, - Optional tableSample, Optional tableSnapshot, List operativeSlots) { + Optional tableSample, Optional tableSnapshot, Collection 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 accept(PlanVisitor visitor, C context) { return visitor.visitLogicalHudiScan(this, context); } + @Override + public LogicalFileScan withOperativeSlots(Collection operativeSlots) { + return new LogicalHudiScan(relationId, (ExternalTable) table, qualifier, + groupExpression, Optional.of(getLogicalProperties()), + selectedPartitions, tableSample, tableSnapshot, scanParams, incrementalRelation, + operativeSlots); + } + /** * Set scan params for incremental read *