fix

risingwavelabs · Dec 28, 2023 · 7d23d03 · 7d23d03
1 parent 55fedb7
commit 7d23d03
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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?;