You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2019/01/31 18:47:16 UTC
[beam] branch master updated: [BEAM-6497] Retry ClickHouse
container startup
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 57a5e36 [BEAM-6497] Retry ClickHouse container startup
new 741e991 Merge pull request #7689: [BEAM-6497] Retry ClickHouse container startup
57a5e36 is described below
commit 57a5e3667487d1ff498f8899481a188dcac03082
Author: Gleb Kanterov <gl...@spotify.com>
AuthorDate: Thu Jan 31 14:39:36 2019 +0100
[BEAM-6497] Retry ClickHouse container startup
- do 10 retries to fix "container not found" error
- use later docker image to avoid possible problem
---
.../java/org/apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/sdks/java/io/clickhouse/src/test/java/org/apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java b/sdks/java/io/clickhouse/src/test/java/org/apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java
index 6323c14..44e98f7 100644
--- a/sdks/java/io/clickhouse/src/test/java/org/apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java
+++ b/sdks/java/io/clickhouse/src/test/java/org/apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java
@@ -44,6 +44,7 @@ public class BaseClickHouseTest {
zookeeper =
new GenericContainer<>("zookeeper:3.4.13")
+ .withStartupAttempts(10)
.withExposedPorts(2181)
.withNetwork(network)
.withNetworkAliases("zookeeper");
@@ -51,7 +52,8 @@ public class BaseClickHouseTest {
clickHouse =
(ClickHouseContainer)
- new ClickHouseContainer()
+ new ClickHouseContainer("yandex/clickhouse-server:19.1")
+ .withStartupAttempts(10)
.withCreateContainerCmdModifier(
// type inference for `(CreateContainerCmd) -> cmd.` doesn't work
cmd ->