alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2599 Fix test failure - SQLServerConnectorIT#verifyOffsets

Browse Source
This commit is contained in:
Chris Cranford 2020-09-24 14:37:40 -04:00 committed by Gunnar Morling
parent 6e83401413
commit c4d1772aee
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
View File

@ -745,6 +745,8 @@ public void verifyOffsets() throws Exception {
final String tableaCT = connection.getNameOfChangeTable("tablea");
final String tablebCT = connection.getNameOfChangeTable("tableb");
TestHelper.waitForCdcRecord(connection, "tableb", rs -> rs.getInt("id") == expectedIds.get(expectedIds.size() - 1));
Awaitility.await().atMost(30, TimeUnit.SECONDS).until(() -> {
// Wait for max lsn to be available
if (!connection.getMaxLsn().isAvailable()) {