From 13952417094993cd67faeace9f891b9a82f99780 Mon Sep 17 00:00:00 2001 From: William Wen Date: Mon, 29 Jul 2024 14:09:00 +0800 Subject: [PATCH] fix --- src/stream/src/task/barrier_manager/managed_state.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/stream/src/task/barrier_manager/managed_state.rs b/src/stream/src/task/barrier_manager/managed_state.rs index 208c8ea1a924a..dfe747ad1a9b5 100644 --- a/src/stream/src/task/barrier_manager/managed_state.rs +++ b/src/stream/src/task/barrier_manager/managed_state.rs @@ -405,7 +405,7 @@ impl InflightActorState { start_prev_epoch ); } else { - assert!(self.status.is_stopping(), "actor has been stopped and has not inflight barrier. unlikely to get further barrier"); + assert!(!self.status.is_stopping(), "actor has been stopped and has not inflight barrier. unlikely to get further barrier"); } self.pending_subscribers .entry(start_prev_epoch)