diff --git a/src/stream/src/executor/sink.rs b/src/stream/src/executor/sink.rs
index b8e786f6f9c40..5dcaa65679ea0 100644
--- a/src/stream/src/executor/sink.rs
+++ b/src/stream/src/executor/sink.rs
@@ -146,7 +146,7 @@ impl<F: LogStoreFactory> SinkExecutor<F> {
             stream_key_sink_pk_mismatch,
         );
 
-        if !self.sink.is_sink_into_table() {
+        if self.sink.is_sink_into_table() {
             #[for_await]
             for msg in processed_input {
                 yield msg?;