From 24cd00b0674ffe14803cd10ee1aedec8e8b74fc8 Mon Sep 17 00:00:00 2001 From: caiq1nyu Date: Tue, 12 May 2026 19:45:03 +0800 Subject: [PATCH 1/2] fix: dummy sink validation failed --- dt-common/src/config/sinker_config.rs | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/dt-common/src/config/sinker_config.rs b/dt-common/src/config/sinker_config.rs index df25b637f..a08e477d1 100644 --- a/dt-common/src/config/sinker_config.rs +++ b/dt-common/src/config/sinker_config.rs @@ -143,7 +143,7 @@ pub enum SinkerConfig { }, } -#[derive(Clone, Debug, Default, Hash)] +#[derive(Clone, Debug, Hash)] pub struct BasicSinkerConfig { pub sink_type: SinkType, pub db_type: DbType, @@ -153,3 +153,16 @@ pub struct BasicSinkerConfig { pub max_connections: u32, pub rate_limiter: RateLimiterConfig, } + +impl Default for BasicSinkerConfig { + fn default() -> Self { + Self { + sink_type: SinkType::default(), + db_type: DbType::default(), + url: String::new(), + connection_auth: ConnectionAuthConfig::default(), + batch_size: 0, + max_connections: 10, + } + } +} From 985500beb703fa59ba5a3018a2f406c5cf059b9a Mon Sep 17 00:00:00 2001 From: caiq1nyu Date: Wed, 13 May 2026 10:32:49 +0800 Subject: [PATCH 2/2] fix after cherrypick --- dt-common/src/config/sinker_config.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/dt-common/src/config/sinker_config.rs b/dt-common/src/config/sinker_config.rs index a08e477d1..f187a010a 100644 --- a/dt-common/src/config/sinker_config.rs +++ b/dt-common/src/config/sinker_config.rs @@ -163,6 +163,7 @@ impl Default for BasicSinkerConfig { connection_auth: ConnectionAuthConfig::default(), batch_size: 0, max_connections: 10, + rate_limiter: RateLimiterConfig::default(), } } }