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

DBZ-4490 Fix randomly failing updatePrimaryKeyWithRestartInMiddle test

Browse Source 
Fix randomly failing
SqlServerConnectorIT#updatePrimaryKeyWithRestartInMiddle.

It seems the main source of instability in slow environments is
consuming snapshot record. It's actually not consumed and as the
test assumes exact order of messages, it leads to failures.

Wait for snapshot to be completed using mbean server. Also add more
asserts to make clear where is the issue if the test continues to fail.
This commit is contained in:
Vojtech Juranek 2022-09-23 13:18:13 +02:00 committed by Jiri Pechanec
parent 63167469c2
commit 0748710d18
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -528,10 +528,13 @@ public void updatePrimaryKeyWithRestartInMiddle() throws Exception {
// Testing.Print.enable();
// Wait for snapshot completion
consumeRecordsByTopic(1);
TestHelper.waitForDatabaseSnapshotToBeCompleted(TestHelper.TEST_DATABASE_1);
final SourceRecords snapshotRecords = consumeRecordsByTopic(1);
Assertions.assertThat(snapshotRecords.allRecordsInOrder()).hasSize(1);
connection.execute("INSERT INTO tableb VALUES(1, 'b')");
consumeRecordsByTopic(1);
final SourceRecords insertRecords = consumeRecordsByTopic(1);
Assertions.assertThat(insertRecords.allRecordsInOrder()).hasSize(1);
connection.setAutoCommit(false);