diff --git a/src/stream/src/executor/sink.rs b/src/stream/src/executor/sink.rs
index fdc2bab87b397..3b90d656cae2b 100644
--- a/src/stream/src/executor/sink.rs
+++ b/src/stream/src/executor/sink.rs
@@ -216,12 +216,9 @@ impl<F: LogStoreFactory> SinkExecutor<F> {
                     yield Message::Chunk(chunk);
                 }
                 Message::Barrier(barrier) => {
-                    // No need to flush barrier to log writer when paused because there will be no data between pause barrier and resume barrier.
-                    if !is_paused {
-                        log_writer
-                            .flush_current_epoch(barrier.epoch.curr, barrier.kind.is_checkpoint())
-                            .await?;
-                    }
+                    log_writer
+                        .flush_current_epoch(barrier.epoch.curr, barrier.kind.is_checkpoint())
+                        .await?;
 
                     if let Some(mutation) = barrier.mutation.as_deref() {
                         match mutation {