fix complie

risingwavelabs · Aug 28, 2024 · 414e7c7 · 414e7c7
1 parent 109b225
commit 414e7c7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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,
@@ -65,7 +67,7 @@ impl<T: TrivialSinkName> Sink for TrivialSink<T> {
     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<bool> {
+    fn is_sink_decouple(_desc: &SinkDesc, _user_specified: &SinkDecouple) -> Result<bool> {
         Ok(false)
     }