diff --git a/it/clickhouse/build.gradle b/it/clickhouse/build.gradle index 858d0dea9207..6afd710fe707 100644 --- a/it/clickhouse/build.gradle +++ b/it/clickhouse/build.gradle @@ -39,7 +39,7 @@ dependencies { implementation library.java.testcontainers_base implementation library.java.testcontainers_clickhouse implementation "com.clickhouse:client-v2:$clickhouse_java_client_version:all" - runtimeOnly "com.clickhouse:clickhouse-jdbc:$clickhouse_java_client_version:all" + implementation "com.clickhouse:clickhouse-jdbc:$clickhouse_java_client_version:all" testImplementation(library.java.truth) testImplementation 'junit:junit:4.13.2' @@ -51,5 +51,5 @@ dependencies { testRuntimeOnly library.java.slf4j_simple permitUnusedDeclared "com.clickhouse:client-v2:$clickhouse_java_client_version:all" - + permitUnusedDeclared "com.clickhouse:clickhouse-jdbc:$clickhouse_java_client_version:all" } \ No newline at end of file diff --git a/it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/ClickHouseResourceManager.java b/it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/ClickHouseResourceManager.java index 093ed918fb17..d24e58efe99d 100644 --- a/it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/ClickHouseResourceManager.java +++ b/it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/ClickHouseResourceManager.java @@ -23,7 +23,6 @@ import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; -import java.time.Duration; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -38,7 +37,6 @@ import org.slf4j.LoggerFactory; import org.testcontainers.clickhouse.ClickHouseContainer; import org.testcontainers.containers.GenericContainer; -import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy; import org.testcontainers.utility.DockerImageName; /** @@ -74,10 +72,6 @@ private static ClickHouseContainer buildContainer(Builder builder) { DockerImageName.parse(builder.containerImageName) .withTag(builder.containerImageTag)) .withStartupAttempts(10); - - Duration startupTimeout = Duration.ofMinutes(2); - container.setWaitStrategy(new LogMessageWaitStrategy().withStartupTimeout(startupTimeout)); - return container; }