feat(query): impl algo for subquery_as_build_side.
@@ -495,7 +495,7 @@ impl PipelineBuilder {
))
})?;
- if join.join_type == JoinType::Mark {
+ if join.join_type == JoinType::Mark && !join.subquery_as_build_side {
self.main_pipeline.resize(1)?;
self.main_pipeline.add_transform(|input, output| {
TransformMarkJoin::try_create(
