From 8972b85f883bdae57131f9a765f3ef89a39eb5c3 Mon Sep 17 00:00:00 2001
From: Patrick Huang <hzxa21@hotmail.com>
Date: Mon, 26 Feb 2024 22:47:56 +0800
Subject: [PATCH] fix assertion

---
 src/stream/src/common/log_store_impl/kv_log_store/writer.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/stream/src/common/log_store_impl/kv_log_store/writer.rs b/src/stream/src/common/log_store_impl/kv_log_store/writer.rs
index b7e559060d67f..b4f54d17ed1d1 100644
--- a/src/stream/src/common/log_store_impl/kv_log_store/writer.rs
+++ b/src/stream/src/common/log_store_impl/kv_log_store/writer.rs
@@ -165,7 +165,7 @@ impl<LS: LocalStateStore> LogWriter for KvLogStoreWriter<LS> {
         if self.is_paused {
             assert_eq!(flush_info.flush_count, 0);
             assert_eq!(flush_info.flush_size, 0);
-            assert!(self.state_store.is_dirty());
+            assert!(!self.state_store.is_dirty());
         }
         flush_info.report(&self.metrics);