From 2d1ce13d7c840542e522b3ba4709489f8d823e15 Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Tue, 16 Jan 2024 07:37:26 +0100 Subject: [PATCH] DBZ-7316 Formatting and cotnributor --- COPYRIGHT.txt | 1 + .../connector/postgresql/RecordsStreamProducerIT.java | 10 +++++----- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index 070c13a76..317aa9da1 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -238,6 +238,7 @@ Ivan Vucina Jackey Zhang Jakub Cechacek James Gormley +James Johnston Jan-Hendrik Dolling Jan Uyttenhove JapuDCret diff --git a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java index f027519fc..e536c8a6f 100644 --- a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java +++ b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java @@ -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);