fmt

risingwavelabs · Jun 24, 2024 · 1b3d85b · 1b3d85b
1 parent 75eab85
commit 1b3d85b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/src/connector/src/source/cdc/external/sql_server.rs b/src/connector/src/source/cdc/external/sql_server.rs
@@ -31,7 +31,6 @@ use tokio_util::compat::{Compat, TokioAsyncWriteCompatExt};
 
 use crate::error::{ConnectorError, ConnectorResult};
 use crate::parser::sql_server_row_to_owned_row;
-#[cfg(not(madsim))]
 use crate::source::cdc::external::{
     CdcOffset, CdcOffsetParseFunc, DebeziumOffset, ExternalTableConfig, ExternalTableReader,
     SchemaTableName,

diff --git a/src/frontend/src/handler/create_source.rs b/src/frontend/src/handler/create_source.rs
@@ -1147,13 +1147,11 @@ pub fn validate_compatibility(
         }
     }
 
-    #[warn(clippy::collapsible_if)]
-    if connector == SQL_SERVER_CDC_CONNECTOR {
-        if !props.contains_key("schema.name") {
-            // Default schema name is "dbo"
-            props.insert("schema.name".into(), "dbo".into());
-        }
+    if connector == SQL_SERVER_CDC_CONNECTOR && !props.contains_key("schema.name") {
+        // Default schema name is "dbo"
+        props.insert("schema.name".into(), "dbo".into());
     }
+
     Ok(())
 }