diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InApplyToJoin.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InApplyToJoin.java index 5a1ba7e22e339b..1848c1680086d1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InApplyToJoin.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InApplyToJoin.java @@ -89,6 +89,7 @@ select t1.k1 from bigtable t1 left semi join (select bitmap_union(k2) x from bit return new LogicalJoin<>(JoinType.LEFT_SEMI_JOIN, Lists.newArrayList(), Lists.newArrayList(expr), JoinHint.NONE, + apply.getMarkJoinSlotReference(), apply.left(), agg); }