use oneside opt

risingwavelabs · Dec 1, 2024 · 6dffc0d · 6dffc0d
1 parent 2166913
commit 6dffc0d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/stream/src/executor/hash_join.rs b/src/stream/src/executor/hash_join.rs
@@ -766,14 +766,14 @@ impl<K: HashKey, S: StateStore, const T: JoinTypePrimitive> HashJoinExecutor<K,
     fn eq_join_left(
         args: EqJoinArgs<'_, K, S>,
     ) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + '_ {
-        Self::eq_join_oneside::<{ SideType::Left }>(args)
+        Self::eq_join_oneside_opt::<{ SideType::Left }>(args)
     }
 
     /// Used to forward `eq_join_oneside` to show join side in stack.
     fn eq_join_right(
         args: EqJoinArgs<'_, K, S>,
     ) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + '_ {
-        Self::eq_join_oneside::<{ SideType::Right }>(args)
+        Self::eq_join_oneside_opt::<{ SideType::Right }>(args)
     }
 
     /// Fetch and match rows