From 2974902b8bbde917909f358bf22bcac7a9240bd4 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Thu, 27 Mar 2025 15:38:35 +0800
Subject: [PATCH] fix: time window filter expr use OR

---
 src/flow/src/recording_rules/engine.rs | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git a/src/flow/src/recording_rules/engine.rs b/src/flow/src/recording_rules/engine.rs
index 2462c6ccc4..3a279a18c9 100644
--- a/src/flow/src/recording_rules/engine.rs
+++ b/src/flow/src/recording_rules/engine.rs
@@ -407,11 +407,8 @@ impl RecordingRuleTask {
             .expect("Time went backwards");
         let low_bound = self
             .expire_after
-            .map(|e| since_the_epoch.as_secs() - e as u64);
-
-        let Some(low_bound) = low_bound else {
-            return Ok(Some(self.query.clone()));
-        };
+            .map(|e| since_the_epoch.as_secs() - e as u64)
+            .unwrap_or(u64::MIN);
 
         let low_bound = Timestamp::new_second(low_bound as i64);
 
@@ -607,7 +604,7 @@ impl DirtyTimeWindows {
             };
             expr_lst.push(expr);
         }
-        let expr = expr_lst.into_iter().reduce(|a, b| a.and(b));
+        let expr = expr_lst.into_iter().reduce(|a, b| a.or(b));
         Ok(expr)
     }