From 5bdf068fd8cb00ac741ef82d8b419a3e2ca471d0 Mon Sep 17 00:00:00 2001 From: Vojtech Juranek Date: Thu, 18 Jul 2024 12:44:47 +0200 Subject: [PATCH] DBZ-8075 Speed-up PostgresShutdownIT test --- .../io/debezium/connector/postgresql/PostgresShutdownIT.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresShutdownIT.java b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresShutdownIT.java index 97c4cf9bd..176659fd6 100644 --- a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresShutdownIT.java +++ b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresShutdownIT.java @@ -27,6 +27,7 @@ import io.debezium.doc.FixFor; import io.debezium.embedded.AbstractConnectorTest; import io.debezium.embedded.EmbeddedEngine; +import io.debezium.embedded.EmbeddedEngineConfig; import io.debezium.heartbeat.DatabaseHeartbeatImpl; import io.debezium.heartbeat.Heartbeat; import io.debezium.jdbc.JdbcConfiguration; @@ -106,7 +107,8 @@ public void shouldStopOnPostgresFastShutdown() throws Exception { .with(PostgresConnectorConfig.DROP_SLOT_ON_STOP, false) .with(PostgresConnectorConfig.SCHEMA_INCLUDE_LIST, "s1") .with(Heartbeat.HEARTBEAT_INTERVAL, 500) - .with(DatabaseHeartbeatImpl.HEARTBEAT_ACTION_QUERY, "UPDATE s1.heartbeat SET ts=NOW();"); + .with(DatabaseHeartbeatImpl.HEARTBEAT_ACTION_QUERY, "UPDATE s1.heartbeat SET ts=NOW();") + .with(EmbeddedEngineConfig.WAIT_FOR_COMPLETION_BEFORE_INTERRUPT_MS, 5_000); // Testing.Print.enable(); PostgresConnection postgresConnection = TestHelper.create();