diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/RepeatNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/RepeatNode.java index 5fef371ec8..f9f136f208 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/RepeatNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/RepeatNode.java @@ -24,10 +24,8 @@ import org.apache.doris.analysis.GroupByClause; import org.apache.doris.analysis.GroupingInfo; import org.apache.doris.analysis.SlotDescriptor; import org.apache.doris.analysis.SlotId; -import org.apache.doris.analysis.SlotRef; import org.apache.doris.analysis.TupleDescriptor; import org.apache.doris.analysis.TupleId; -import org.apache.doris.analysis.VirtualSlotRef; import org.apache.doris.common.UserException; import org.apache.doris.statistics.StatisticalType; import org.apache.doris.statistics.StatsRecursiveDerive; @@ -126,12 +124,6 @@ public class RepeatNode extends PlanNode { outputTupleDesc.setTable(analyzer.getTupleDesc(inputTupleIds.get(0)).getTable()); } - //set aggregate nullable - for (Expr slot : groupByClause.getGroupingExprs()) { - if (slot instanceof SlotRef && !(slot instanceof VirtualSlotRef)) { - ((SlotRef) slot).getDesc().setIsNullable(true); - } - } outputTupleDesc.computeStatAndMemLayout(); List> groupingIdList = new ArrayList<>();