hardcode specific sink

kwannoel · kwannoel · commit 991660252079 · 2025-05-31T10:17:12.000+08:00
diff --git a/src/stream/src/from_proto/sink.rs b/src/stream/src/from_proto/sink.rs
@@ -168,6 +168,7 @@ impl ExecutorBuilder for SinkExecutorBuilder {
             && connector_type == "jdbc"
             && let Some(url) = properties_with_secret.get("jdbc.url")
             && url.starts_with("jdbc:postgresql:")
+            && sink_name == "multiverse_people"
         {
             tracing::info!("switching to native postgres connector");
             let jdbc_url = parse_jdbc_url(url)

Original file line number	Diff line number	Diff line change
`@@ -168,6 +168,7 @@ impl ExecutorBuilder for SinkExecutorBuilder {`
`168`	`168`	`&& connector_type == "jdbc"`
`169`	`169`	`&& let Some(url) = properties_with_secret.get("jdbc.url")`
`170`	`170`	`&& url.starts_with("jdbc:postgresql:")`
	`171`	`+ && sink_name == "multiverse_people"`
`171`	`172`	`{`
`172`	`173`	`tracing::info!("switching to native postgres connector");`
`173`	`174`	`let jdbc_url = parse_jdbc_url(url)`