From 3155cd6e017e5ec22e35eead4608bbaf0eb0a4ab Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Fri, 11 Aug 2023 17:08:49 +0800 Subject: [PATCH] fix --- src/stream/src/executor/backfill/no_shuffle_backfill.rs | 2 ++ 1 file changed, 2 insertions(+) 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