fix assertion

risingwavelabs · Feb 26, 2024 · 8972b85 · 8972b85
1 parent bf1f233
commit 8972b85
Showing 1 changed file with 1 addition and 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
@@ -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);