From 26340f1d250d709fa118bd146c93b3de19a80112 Mon Sep 17 00:00:00 2001
From: Patrick Huang <hzxa21@hotmail.com>
Date: Thu, 22 Feb 2024 17:05:43 +0800
Subject: [PATCH] fix space

---
 src/stream/src/executor/sink.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/stream/src/executor/sink.rs b/src/stream/src/executor/sink.rs
index 6b2f37615749..fdc2bab87b39 100644
--- a/src/stream/src/executor/sink.rs
+++ b/src/stream/src/executor/sink.rs
@@ -216,8 +216,7 @@ 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.
+                    // 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())