diff --git a/src/connector/src/sink/trivial.rs b/src/connector/src/sink/trivial.rs index 0cfa82c5c4d1..5c5e093c8e0f 100644 --- a/src/connector/src/sink/trivial.rs +++ b/src/connector/src/sink/trivial.rs @@ -15,7 +15,9 @@ use std::marker::PhantomData; use async_trait::async_trait; +use risingwave_common::session_config::sink_decouple::SinkDecouple; +use super::catalog::desc::SinkDesc; use crate::sink::log_store::{LogStoreReadItem, TruncateOffset}; use crate::sink::{ DummySinkCommitCoordinator, LogSinker, Result, Sink, SinkError, SinkLogReader, SinkParam, @@ -64,6 +66,11 @@ impl Sink for TrivialSink { const SINK_NAME: &'static str = T::SINK_NAME; + // Disable sink decoupling for all trivial sinks because it introduces overhead without any benefit + fn is_sink_decouple(_desc: &SinkDesc, _user_specified: &SinkDecouple) -> Result { + Ok(false) + } + async fn new_log_sinker(&self, _writer_env: SinkWriterParam) -> Result { Ok(Self(PhantomData)) }