collect metric info

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Oct 10, 2024 · ed01419 · ed01419
1 parent a5a1b29
commit ed01419
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/stream/src/executor/over_window/general.rs b/src/stream/src/executor/over_window/general.rs
@@ -415,6 +415,12 @@ impl<S: StateStore> OverWindowExecutor<S> {
             metrics
                 .over_window_range_cache_right_miss_count
                 .inc_by(stats.right_miss_count);
+            metrics
+                .over_window_compute_count
+                .inc_by(stats.compute_count);
+            metrics
+                .over_window_same_result_count
+                .inc_by(stats.same_result_count);
 
             // Update recently accessed range for later shrinking cache.
             if !this.cache_policy.is_full()