From 5b3bb5ec821d8cf9e9b75a9bdd5faf5a01a80b71 Mon Sep 17 00:00:00 2001
From: TennyZhuang <zty0826@gmail.com>
Date: Mon, 19 Feb 2024 14:13:11 +0800
Subject: [PATCH] update comment

Signed-off-by: TennyZhuang <zty0826@gmail.com>
---
 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 b3665c41689dc..da0ac7b45dbdc 100644
--- a/src/stream/src/executor/temporal_join.rs
+++ b/src/stream/src/executor/temporal_join.rs
@@ -117,8 +117,8 @@ struct TemporalSide<K: HashKey, S: StateStore> {
 }
 
 impl<K: HashKey, S: StateStore> TemporalSide<K, S> {
-    /// Lookup the temporal side table and return a `JoinEntry` which could be empty if there are no
-    /// matched records.
+    /// Fetch records from temporal side table and ensure the entry in the cache.
+    /// If already exists, the entry will be promoted.
     async fn fetch_or_promote_keys(
         &mut self,
         keys: impl Iterator<Item = &K>,