diff --git a/src/batch/src/executor/join/local_lookup_join.rs b/src/batch/src/executor/join/local_lookup_join.rs index 6a968540ca879..37e493741f7b5 100644 --- a/src/batch/src/executor/join/local_lookup_join.rs +++ b/src/batch/src/executor/join/local_lookup_join.rs @@ -387,8 +387,6 @@ impl BoxedExecutorBuilder for LocalLookupJoinExecutorBuilder { }) .collect(); - assert_eq!(worker_slot_mapping.len(), worker_nodes.len()); - let inner_side_builder = InnerSideExecutorBuilder { table_desc: table_desc.clone(), table_distribution: TableDistribution::new_from_storage_table_desc(