finish writer outside

risingwavelabs · Feb 27, 2025 · 494bafc · 494bafc
1 parent 7d78010
commit 494bafc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/stream/src/executor/sync_kv_log_store.rs b/src/stream/src/executor/sync_kv_log_store.rs
@@ -572,11 +572,11 @@ impl<S: StateStore> SyncedKvLogStoreExecutor<S> {
                     | LogStoreBufferItem::UpdateVnodes(_) => {}
                 }
             }
-
-            let (flush_info, _) = writer.finish().await?;
-            flush_info.report(metrics);
         }
+
         // Apply truncation
+        let (flush_info, _) = writer.finish().await?;
+        flush_info.report(metrics);
         let post_seal = write_state.seal_current_epoch(barrier.epoch.curr, truncation_offset);
 
         // Add to buffer