[cdc-connector][sqlserver][tests] Fix UT errors by increasing the wait time after committing SQL (#2799)

This closes #2799.
pull/2803/head
Xin Gong 1 year ago committed by GitHub
parent 173deb5248
commit 2d9dc018c5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

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

Loading…
Cancel
Save