From 2472ba3f8928cc3c54997679fe4fcb5ce27b09e8 Mon Sep 17 00:00:00 2001 From: TennyZhuang Date: Fri, 23 Feb 2024 17:48:35 +0800 Subject: [PATCH] refine comments Signed-off-by: TennyZhuang --- src/stream/src/executor/temporal_join.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/stream/src/executor/temporal_join.rs b/src/stream/src/executor/temporal_join.rs index fe096e06d515d..8e31e3bd6f28c 100644 --- a/src/stream/src/executor/temporal_join.rs +++ b/src/stream/src/executor/temporal_join.rs @@ -401,7 +401,7 @@ impl TemporalJoinExecutor yield Message::Watermark(watermark.with_idx(output_watermark_col_idx)); } InternalMessage::Chunk(chunk) => { - // Joined result without evaluating other conditions. + // Joined result without evaluating non-lookup conditions. let st1 = { #[try_stream] async { @@ -470,7 +470,7 @@ impl TemporalJoinExecutor #[for_await] for item in st1 { let (chunk, row_matched) = item?; - // check other join conditions + // check non-lookup join conditions if !row_matched.is_empty() && let Some(ref cond) = self.condition {