diff --git a/src/connector/src/sink/mod.rs b/src/connector/src/sink/mod.rs index b288abc7cc150..47a4a39f7fd9d 100644 --- a/src/connector/src/sink/mod.rs +++ b/src/connector/src/sink/mod.rs @@ -77,7 +77,7 @@ use crate::sink::catalog::desc::SinkDesc; use crate::sink::catalog::{SinkCatalog, SinkId}; use crate::sink::file_sink::fs::FsSink; // use crate::sink::file_sink::gcs::GcsSink; -// use crate::sink::file_sink::s3::S3Sink; +use crate::sink::file_sink::s3::S3Sink; use crate::sink::log_store::{LogReader, LogStoreReadItem, LogStoreResult, TruncateOffset}; use crate::sink::writer::SinkWriter; const BOUNDED_CHANNEL_SIZE: usize = 16; @@ -103,7 +103,7 @@ macro_rules! for_all_sinks { { HttpJava, $crate::sink::remote::HttpJavaSink }, { Doris, $crate::sink::doris::DorisSink }, { Starrocks, $crate::sink::starrocks::StarrocksSink }, - // { S3, $crate::sink::file_sink::opendal_sink::FileSink }, + { S3, $crate::sink::file_sink::opendal_sink::FileSink }, // { Gcs, $crate::sink::file_sink::opendal_sink::FileSink }, { Fs, $crate::sink::file_sink::opendal_sink::FileSink }, { Snowflake, $crate::sink::snowflake::SnowflakeSink }, diff --git a/src/frontend/src/optimizer/plan_node/stream_sink.rs b/src/frontend/src/optimizer/plan_node/stream_sink.rs index e2d1893a55340..4c371e3867ba1 100644 --- a/src/frontend/src/optimizer/plan_node/stream_sink.rs +++ b/src/frontend/src/optimizer/plan_node/stream_sink.rs @@ -28,7 +28,7 @@ use risingwave_connector::sink::catalog::desc::SinkDesc; use risingwave_connector::sink::catalog::{SinkFormat, SinkFormatDesc, SinkId, SinkType}; use risingwave_connector::sink::file_sink::fs::FsSink; // use risingwave_connector::sink::file_sink::gcs::GcsSink; -// use risingwave_connector::sink::file_sink::s3::S3Sink; +use risingwave_connector::sink::file_sink::s3::S3Sink; use risingwave_connector::sink::iceberg::ICEBERG_SINK; use risingwave_connector::sink::trivial::TABLE_SINK; use risingwave_connector::sink::{ diff --git a/src/stream/src/from_proto/sink.rs b/src/stream/src/from_proto/sink.rs index b4697e53ad5a7..c81c99dfee1da 100644 --- a/src/stream/src/from_proto/sink.rs +++ b/src/stream/src/from_proto/sink.rs @@ -22,7 +22,7 @@ use risingwave_connector::match_sink_name_str; use risingwave_connector::sink::catalog::{SinkFormatDesc, SinkId, SinkType}; use risingwave_connector::sink::file_sink::fs::FsSink; // use risingwave_connector::sink::file_sink::gcs::GcsSink; -// use risingwave_connector::sink::file_sink::s3::S3Sink; +use risingwave_connector::sink::file_sink::s3::S3Sink; use risingwave_connector::sink::{ SinkError, SinkMetaClient, SinkParam, SinkWriterParam, CONNECTOR_TYPE_KEY, SINK_TYPE_OPTION, };