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

DBZ-7316 Formatting and cotnributor

Browse Source
This commit is contained in:
Jiri Pechanec 2024-01-16 07:37:26 +01:00
parent 20fbbd6452
commit 2d1ce13d7c
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
COPYRIGHT.txt
View File

@ -238,6 +238,7 @@ Ivan Vucina
Jackey Zhang
Jakub Cechacek
James Gormley
James Johnston
Jan-Hendrik Dolling
Jan Uyttenhove
JapuDCret

10
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
View File

@ -3765,7 +3765,7 @@ public void testSendingHeartbeatsWithoutWalUpdates() throws Exception {
.with(PostgresConnectorConfig.DROP_SLOT_ON_STOP, false);
// Start and stop the connector to ensure that the replication slot is created, and also
// to test that some initial heartbeats are created (DBZ-6635). Note that even though we
// to test that some initial heartbeats are created (DBZ-6635). Note that even though we
// aren't explicitly making any database changes to stream here, PG often will have some
// WAL activity to consume anyway that the searchWalPosition function will find.
startConnector(configMapper);
@ -3777,8 +3777,8 @@ public void testSendingHeartbeatsWithoutWalUpdates() throws Exception {
// starting completely fresh with the connector restart.
consumeAvailableRecords(null);
// Also make sure that the PG replication slot is COMPLETELY CLEARED. (While manually reproducing DBZ-7316
// it was noted that sometimes there is still WAL to consume after the connector is stopped. So this is just
// Also make sure that the PG replication slot is COMPLETELY CLEARED. (While manually reproducing DBZ-7316
// it was noted that sometimes there is still WAL to consume after the connector is stopped. So this is just
// being extra-safe that the next portion of the test really tests with an empty WAL to consume).
TestHelper.execute(getReplicationSlotChangesQuery());
try (PostgresConnection connection = TestHelper.create()) {
@ -3793,8 +3793,8 @@ public void testSendingHeartbeatsWithoutWalUpdates() throws Exception {
assertThat(changeCount).isEqualTo(0);
}
// Start the connector again. This time, we're resuming from an existing replication slot,
// so the searchWalPosition function will be looking for a place to resume. We need to
// Start the connector again. This time, we're resuming from an existing replication slot,
// so the searchWalPosition function will be looking for a place to resume. We need to
// test that the loop in searchWalPosition is emitting heartbeats (DBZ-7316) when there
// is no WAL to consume (since we just cleared it out and asserted there was none).
startConnector(configMapper);