[IR Runtime] fix bug in filtering after intersect

Committed-by: bingqing.lbq from Dev container
shirly121 · Nov 16, 2023 · cd818b8 · cd818b8
1 parent eefda74
commit cd818b8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/interactive_engine/executor/ir/core/src/plan/physical.rs b/interactive_engine/executor/ir/core/src/plan/physical.rs
@@ -1089,6 +1089,9 @@ fn add_intersect_job_builder(
     // add vertex filters
     if let Some(mut auxilia) = auxilia {
         auxilia.tag = Some(intersect_tag.clone());
+        if plan_meta.is_partition() {
+            builder.shuffle(Some(intersect_tag.clone()));
+        }
         builder.get_v(auxilia);
     }
     Ok(())