diff --git a/src/stream/src/executor/approx_percentile/global.rs b/src/stream/src/executor/approx_percentile/global.rs
index fafca4c38ff25..534857237bffb 100644
--- 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
index f71bbaf1fe66d..b50419342c0d7 100644
--- 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(_) => {}
             }
         }
     }