diff --git a/src/stream/src/executor/backfill/no_shuffle_backfill.rs b/src/stream/src/executor/backfill/no_shuffle_backfill.rs index 003b64c392d9b..ec1f67150fa80 100644 --- a/src/stream/src/executor/backfill/no_shuffle_backfill.rs +++ b/src/stream/src/executor/backfill/no_shuffle_backfill.rs @@ -284,6 +284,8 @@ where &self.output_indices, )); } + } else { + upstream_chunk_buffer.clear(); } self.metrics