From 2d9dc018c5ee3396c5a091f07f5a1c873e848c2c Mon Sep 17 00:00:00 2001
From: Xin Gong <genzhedangdang@gmail.com>
Date: Sat, 2 Dec 2023 22:30:55 +0800
Subject: [PATCH] [cdc-connector][sqlserver][tests] Fix UT errors by increasing
 the wait time after committing SQL (#2799)

This closes #2799.
---
 .../sqlserver/source/SqlServerSourceITCase.java           | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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);
                     }