diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java index ce4b0f522b3a7a..d37a47fd651a1b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java @@ -250,6 +250,9 @@ public Plan visitPhysicalOneRowRelation(PhysicalOneRowRelation oneRowRelation, C @Override public PhysicalRelation visitPhysicalRelation(PhysicalRelation relation, CascadesContext context) { + if (relation instanceof PhysicalSchemaScan) { + return relation; + } // add all the slots in map. RuntimeFilterContext ctx = context.getRuntimeFilterContext(); relation.getOutput().forEach(slot -> ctx.getAliasTransferMap().put(slot, Pair.of(relation, slot)));