fix space

risingwavelabs · Feb 22, 2024 · 26340f1 · 26340f1
1 parent 806185d
commit 26340f1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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())