diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java
index 39271ecca..c563199ab 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java
@@ -310,12 +310,12 @@ public class SqlServerSourceITCase extends SqlServerSourceTestBase {
                 (sourceConfig, split) -> {
                     SqlServerDialect dialect =
                             new SqlServerDialect((SqlServerSourceConfig) sourceConfig);
-                    JdbcConnection postgresConnection =
+                    JdbcConnection sqlServerConnection =
                             dialect.openJdbcConnection((JdbcSourceConfig) sourceConfig);
-                    postgresConnection.execute(statements);
-                    postgresConnection.commit();
+                    sqlServerConnection.execute(statements);
+                    sqlServerConnection.commit();
                     try {
-                        Thread.sleep(1000L);
+                        Thread.sleep(5000L);
                     } catch (InterruptedException e) {
                         throw new RuntimeException(e);
                     }