ignore watermarks

risingwavelabs · Aug 7, 2024 · 66ecdea · 66ecdea
1 parent 84c656f
commit 66ecdea
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/stream/src/executor/approx_percentile/global.rs b/src/stream/src/executor/approx_percentile/global.rs
@@ -175,7 +175,7 @@ impl<S: StateStore> GlobalApproxPercentileExecutor<S> {
 
                     yield Message::Barrier(barrier);
                 }
-                m => yield m,
+                Message::Watermark(_) => {}
             }
         }
     }

diff --git a/src/stream/src/executor/approx_percentile/local.rs b/src/stream/src/executor/approx_percentile/local.rs
@@ -112,7 +112,8 @@ impl LocalApproxPercentileExecutor {
                         yield Message::Chunk(chunk);
                     }
                 }
-                m => yield m,
+                b @ Message::Barrier(_) => yield b,
+                Message::Watermark(_) => {}
             }
         }
     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -175,7 +175,7 @@ impl<S: StateStore> GlobalApproxPercentileExecutor<S> { @@
                         yield Message::Barrier(barrier);
                     }
-                    m => yield m,
+                    Message::Watermark(_) => {}
                 }
             }
         }
@@ Expand Down @@