From c4ec7d5f220e743b1c19ee147cc1bb31ead21afb Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 16 Jul 2024 13:43:44 -0400 Subject: [PATCH] Increase timeout in Debezium tests --- .../integration/debezium/dsl/DebeziumDslTests.java | 4 ++-- .../integration/debezium/it/DebeziumBatchTests.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/dsl/DebeziumDslTests.java b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/dsl/DebeziumDslTests.java index 5f660de367..04a7345884 100644 --- a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/dsl/DebeziumDslTests.java +++ b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/dsl/DebeziumDslTests.java @@ -60,7 +60,7 @@ public class DebeziumDslTests implements DebeziumMySqlTestContainer { @Test void dslFromBuilder() throws InterruptedException { - assertThat(config.latch.await(30, TimeUnit.SECONDS)).isTrue(); + assertThat(config.latch.await(1, TimeUnit.MINUTES)).isTrue(); assertThat(config.payloads).hasSize(EXPECTED_DB_TX_COUNT); assertThat(config.headerKeys).hasSize(EXPECTED_DB_TX_COUNT); @@ -74,7 +74,7 @@ public class DebeziumDslTests implements DebeziumMySqlTestContainer { @Test void dslBatch() throws InterruptedException { - assertThat(config.batchLatch.await(30, TimeUnit.SECONDS)).isTrue(); + assertThat(config.batchLatch.await(1, TimeUnit.MINUTES)).isTrue(); assertThat(config.bachPayloads) .as("Sum of the message payload counts should correspond to the number of DB transactions") .hasSize(EXPECTED_DB_TX_COUNT); diff --git a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumBatchTests.java b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumBatchTests.java index b728713a51..a3630f30d5 100644 --- a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumBatchTests.java +++ b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumBatchTests.java @@ -63,7 +63,7 @@ public class DebeziumBatchTests implements DebeziumMySqlTestContainer { @Test void batchMode() { - await().atMost(Duration.ofSeconds(30)).until(this::receivePayloads, (count) -> count == EXPECTED_DB_TX_COUNT); + await().atMost(Duration.ofMinutes(1)).until(this::receivePayloads, (count) -> count == EXPECTED_DB_TX_COUNT); assertThat(allPayload).hasSize(EXPECTED_DB_TX_COUNT); assertThat(batchCount).isLessThan(EXPECTED_DB_TX_COUNT);