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 d2db0183467f80..fdf6efb81675d5 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 @@ -90,6 +90,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), new DistributeHint(DistributeType.NONE), + apply.getMarkJoinSlotReference(), apply.left(), agg, null); }