[
https://issues.apache.org/jira/browse/BEAM-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975285#comment-16975285
]
Tomo Suzuki edited comment on BEAM-8650 at 11/15/19 6:09 PM:
-------------------------------------------------------------
[~kanterov] That Gist is super helpful. In my network, while DNS resolution ()
works, the TCP connection seems to be dropped as if it's filtered by firewall.
Security rule for my machine/docker? I'll dig further.
{noformat}
root@70d7b8b37351:/# apt-get update && apt-get install zookeeper
Err:1 http://repo.yandex.ru/clickhouse/deb/stable main/ InRelease
Could not connect to repo.yandex.ru:80 (213.180.204.183), connection timed out
...
suztomo@suxtomo24:~/beam6$ docker exec -it 70d7b8b37351 /bin/bash
root@70d7b8b37351:/# ps -ef |grep -i clickhouse
clickho+ 1 0 0 17:44 ? 00:00:02 /usr/bin/clickhouse-server
--config-file=/etc/clickhouse-server/config.xml
root 127 117 0 17:56 pts/0 00:00:00 grep --color=auto -i
clickhouse
root@70d7b8b37351:/# wget http://zookeeper:2181/
--2019-11-15 17:56:52-- http://zookeeper:2181/ # using wget instead of
telnet
Resolving zookeeper (zookeeper)... 172.25.0.2
Connecting to zookeeper (zookeeper)|172.25.0.2|:2181... ^C
root@70d7b8b37351:/# wget http://zookeeper:8888/ # Irrelevant port
--2019-11-15 17:57:06-- http://zookeeper:8888/
Resolving zookeeper (zookeeper)... 172.25.0.2
Connecting to zookeeper (zookeeper)|172.25.0.2|:8888...
{noformat}
Security policy? But ClickHouseIOTest always succeeds. Tried the wget in the
container but failed. It seems that ClickHouseIOTest does not require
connection to zookeeper.
was (Author: suztomo):
[~kanterov] That Gist is super helpful. In my network, while DNS resolution ()
works, the TCP connection seems to be dropped as if it's filtered by firewall.
Security rule for my machine/docker? I'll dig further.
{noformat}
root@70d7b8b37351:/# apt-get update && apt-get install zookeeper
Err:1 http://repo.yandex.ru/clickhouse/deb/stable main/ InRelease
Could not connect to repo.yandex.ru:80 (213.180.204.183), connection timed out
...
suztomo@suxtomo24:~/beam6$ docker exec -it 70d7b8b37351 /bin/bash
root@70d7b8b37351:/# ps -ef |grep -i clickhouse
clickho+ 1 0 0 17:44 ? 00:00:02 /usr/bin/clickhouse-server
--config-file=/etc/clickhouse-server/config.xml
root 127 117 0 17:56 pts/0 00:00:00 grep --color=auto -i
clickhouse
root@70d7b8b37351:/# wget http://zookeeper:2181/
--2019-11-15 17:56:52-- http://zookeeper:2181/ # using wget instead of
telnet
Resolving zookeeper (zookeeper)... 172.25.0.2
Connecting to zookeeper (zookeeper)|172.25.0.2|:2181... ^C
root@70d7b8b37351:/# wget http://zookeeper:8888/ # Irrelevant port
--2019-11-15 17:57:06-- http://zookeeper:8888/
Resolving zookeeper (zookeeper)... 172.25.0.2
Connecting to zookeeper (zookeeper)|172.25.0.2|:8888...
{noformat}
Security policy? But ClickHouseIOTest always succeeds.
> org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert fails
> -----------------------------------------------------------------------------
>
> Key: BEAM-8650
> URL: https://issues.apache.org/jira/browse/BEAM-8650
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-core
> Environment: JVM: 1.8.0_232 (Debian 25.232-b09)
> Reporter: Tomo Suzuki
> Priority: Major
> Attachments: clickhouse-server.err.log, clickhouse-server.log
>
>
> The test fails in my development environment.
> BEAM-6388 (fixed in January 2019) seems similar. -> No the reason of the
> error is different.
> {noformat}
> suztomo@suxtomo24:~/beam4$ ./gradlew -p sdks/java/io/clickhouse check
> Configuration on demand is an incubating feature.> Task
> :sdks:java:io:clickhouse:testorg.apache.beam.sdk.io.clickhouse.AtomicInsertTest
> > testIdempotentInsert FAILED
> ru.yandex.clickhouse.except.ClickHouseException at AtomicInsertTest.java:100
> Caused by: java.lang.Throwable at AtomicInsertTest.java:10034 tests
> completed, 1 failed> Task :sdks:java:io:clickhouse:test FAILEDFAILURE: Build
> failed with an exception.* What went wrong:
> Execution failed for task ':sdks:java:io:clickhouse:test'.
> > There were failing tests. See the report at:
> > file:///usr/local/google/home/suztomo/beam4/sdks/java/io/clickhouse/build/reports/tests/test/index.html*
> > Try:
> Run with --stacktrace option to get the stack trace. Run with --info or
> --debug option to get more log output. Run with --scan to get full insights.*
> Get more help at https://help.gradle.orgDeprecated Gradle features were used
> in this build, making it incompatible with Gradle 6.0.
> Use '--warning-mode all' to show the individual deprecation warnings.
> See
> https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warningsBUILD
> FAILED in 58s
> 52 actionable tasks: 1 executed, 51 up-to-date
> suztomo@suxtomo24:~/beam4$ git log -1
> commit a6d3980fcb18562ad6abba562766efdddc32abcf (HEAD -> master)
> Merge: 04030344ca 47eac13854
> Author: Tomo Suzuki <[email protected]>
> Date: Wed Nov 13 13:19:52 2019 -0500Merge branch 'master' of
> https://gitbox.apache.org/repos/asf/beam
> suztomo@suxtomo24:~/beam4$ ./gradlew
> -version------------------------------------------------------------
> Gradle 5.2.1
> ------------------------------------------------------------Build time:
> 2019-02-08 19:00:10 UTC
> Revision: f02764e074c32ee8851a4e1877dd1fea8ffb7183Kotlin DSL: 1.1.3
> Kotlin: 1.3.20
> Groovy: 2.5.4
> Ant: Apache Ant(TM) version 1.9.13 compiled on July 10 2018
> JVM: 1.8.0_232 (Debian 25.232-b09)
> OS: Linux 4.19.67-2rodete2-amd64 amd64{noformat}
>
> The HTML has the stacktrace:
> [https://gist.github.com/suztomo/39d00252a1e158479f44cc0baa59b6ad]
>
> {noformat}
> Nov 13, 2019 1:43:55 PM
> org.testcontainers.dockerclient.DockerClientProviderStrategy
> lambda$getFirstValidStrategy$1
> INFO: Loaded
> org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy
> from ~/.testcontainers.properties, will try it first
> Nov 13, 2019 1:43:55 PM
> org.testcontainers.dockerclient.DockerClientProviderStrategy
> getClientForConfig
> INFO: Will use 'okhttp' transport
> Nov 13, 2019 1:43:56 PM
> org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy
> test
> INFO: Found docker client settings from environment
> Nov 13, 2019 1:43:56 PM
> org.testcontainers.dockerclient.DockerClientProviderStrategy
> lambda$getFirstValidStrategy$2
> INFO: Found Docker environment with Environment variables, system properties
> and defaults. Resolved:
> dockerHost=unix:///var/run/docker.sock
> apiVersion='{UNKNOWN_VERSION}'
> registryUrl='https://index.docker.io/v1/'
> registryUsername='suztomo'
> registryPassword='null'
> registryEmail='null'
>
> dockerConfig='DefaultDockerClientConfig[dockerHost=unix:///var/run/docker.sock,registryUsername=suztomo,registryPassword=<null>,registryEmail=<null>,registryUrl=https://index.docker.io/v1/,dockerConfigPath=/usr/local/google/home/suztomo/.docker,sslConfig=<null>,apiVersion={UNKNOWN_VERSION},dockerConfig=<null>]'
> Nov 13, 2019 1:43:56 PM org.testcontainers.DockerClientFactory client
> INFO: Docker host IP address is localhost
> Nov 13, 2019 1:43:56 PM org.testcontainers.DockerClientFactory client
> INFO: Connected to docker:
> Server Version: 18.09.4
> API Version: 1.39
> Operating System: Debian GNU/Linux bullseye/sid
> Total Memory: 64146 MB
> Nov 13, 2019 1:43:57 PM org.testcontainers.DockerClientFactory client
> INFO: Ryuk started - will monitor and terminate Testcontainers containers on
> JVM exit
> ℹ︎ Checking the system...
> ✔ Docker version should be at least 1.6.0
> ✔ Docker environment should have more than 2GB free disk space
> Nov 13, 2019 1:43:57 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Creating container for image: zookeeper:3.4.13
> Nov 13, 2019 1:43:57 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Starting container with ID:
> 1d73211e7d8394039c0877d892cfde79f2f6460b20242c59eec8bc2402e0181d
> Nov 13, 2019 1:43:58 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Container zookeeper:3.4.13 is starting:
> 1d73211e7d8394039c0877d892cfde79f2f6460b20242c59eec8bc2402e0181d
> Nov 13, 2019 1:43:59 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Container zookeeper:3.4.13 started
> Nov 13, 2019 1:43:59 PM org.testcontainers.images.RemoteDockerImage resolve
> INFO: Pulling docker image:
> yandex/clickhouse-server@sha256:c75f66f3619ca70a9f7215966505eaed2fc0ca0ee7d6a7b5407d1b14df8ddefc.
> Please be patient; this may take some time but only needs to be done once.
> Nov 13, 2019 1:43:59 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Creating container for image:
> yandex/clickhouse-server@sha256:c75f66f3619ca70a9f7215966505eaed2fc0ca0ee7d6a7b5407d1b14df8ddefc
> Nov 13, 2019 1:44:01 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Starting container with ID:
> 552a249505f077ad32ecf033a3995faa53205b6e1b6a00d859237574cf8f3d3e
> Nov 13, 2019 1:44:01 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Container
> yandex/clickhouse-server@sha256:c75f66f3619ca70a9f7215966505eaed2fc0ca0ee7d6a7b5407d1b14df8ddefc
> is starting: 552a249505f077ad32ecf033a3995faa53205b6e1b6a00d859237574cf8f3d3e
> Nov 13, 2019 1:44:01 PM org.testcontainers.containers.JdbcDatabaseContainer
> waitUntilContainerStarted
> INFO: Waiting for database connection to become available at
> jdbc:clickhouse://localhost:32840/default using query 'SELECT 1'
> Nov 13, 2019 1:44:01 PM ru.yandex.clickhouse.ClickHouseDriver <clinit>
> INFO: Driver registered
> Nov 13, 2019 1:44:01 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@3916d9b1, reporting
> failure to data source, message: localhost:32840 failed to respond
> Nov 13, 2019 1:44:01 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@2eae3dd2, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@5aaaa995, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@758a5c41, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@5592146c, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@419bd968, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@25d3153f, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@74e27c0a, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@59f16143, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error during connection to
> ru.yandex.clickhouse.settings.ClickHouseProperties@16a03fd9, reporting
> failure to data source, message: Connection reset
> Nov 13, 2019 1:44:02 PM ru.yandex.clickhouse.ClickHouseStatementImpl
> getInputStream
> INFO: Error sql: select timezone() FORMAT TabSeparatedWithNamesAndTypes;
> Nov 13, 2019 1:44:03 PM org.testcontainers.containers.JdbcDatabaseContainer
> lambda$waitUntilContainerStarted$0
> INFO: Obtained a connection to container
> (jdbc:clickhouse://localhost:32840/default)
> Nov 13, 2019 1:44:03 PM org.testcontainers.containers.GenericContainer
> tryStart
> INFO: Container
> yandex/clickhouse-server@sha256:c75f66f3619ca70a9f7215966505eaed2fc0ca0ee7d6a7b5407d1b14df8ddefc
> started
> Nov 13, 2019 1:44:14 PM
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn flush
> WARNING: Error writing to ClickHouse. Retry attempt[0]
> ru.yandex.clickhouse.except.ClickHouseException: ClickHouse exception, code:
> 32, host: localhost, port: 32840; Code: 32, e.displayText() = DB::Exception:
> Attempt to read after eof: Cannot parse Int64 from String, because value is
> too short, e.what() = DB::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:58)
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:28)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.checkForErrorAndThrow(ClickHouseStatementImpl.java:766)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendStream(ClickHouseStatementImpl.java:742)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream(ClickHouseStatementImpl.java:691)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream(ClickHouseStatementImpl.java:686)
> at
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn.flush(ClickHouseIO.java:427)
> at
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn.processElement(ClickHouseIO.java:411)
> at
> org.apache.beam.sdk.io.clickhouse.AutoValue_ClickHouseIO_WriteFn$DoFnInvoker.invokeProcessElement(Unknown
> Source)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:218)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:183)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
> at
> org.apache.beam.runners.direct.ParDoEvaluator.processElement(ParDoEvaluator.java:216)
> at
> org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:54)
> at
> org.apache.beam.runners.direct.DirectTransformExecutor.processElements(DirectTransformExecutor.java:160)
> at
> org.apache.beam.runners.direct.DirectTransformExecutor.run(DirectTransformExecutor.java:124)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.Throwable: Code: 32, e.displayText() = DB::Exception:
> Attempt to read after eof: Cannot parse Int64 from String, because value is
> too short, e.what() = DB::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:53)
> ... 20 more
> Nov 13, 2019 1:44:14 PM
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn flush
> WARNING: Error writing to ClickHouse. Retry attempt[1]
> ru.yandex.clickhouse.except.ClickHouseException: ClickHouse exception, code:
> 32, host: localhost, port: 32840; Code: 32, e.displayText() = DB::Exception:
> Attempt to read after eof: Cannot parse Int64 from String, because value is
> too short, e.what() = DB::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:58)
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:28)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.checkForErrorAndThrow(ClickHouseStatementImpl.java:766)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendStream(ClickHouseStatementImpl.java:742)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream(ClickHouseStatementImpl.java:691)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream(ClickHouseStatementImpl.java:686)
> at
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn.flush(ClickHouseIO.java:427)
> at
> org.apache.beam.sdk.io.clickhouse.ClickHouseIO$WriteFn.processElement(ClickHouseIO.java:411)
> at
> org.apache.beam.sdk.io.clickhouse.AutoValue_ClickHouseIO_WriteFn$DoFnInvoker.invokeProcessElement(Unknown
> Source)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:218)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:183)
> at
> org.apache.beam.repackaged.direct_java.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
> at
> org.apache.beam.runners.direct.ParDoEvaluator.processElement(ParDoEvaluator.java:216)
> at
> org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:54)
> at
> org.apache.beam.runners.direct.DirectTransformExecutor.processElements(DirectTransformExecutor.java:160)
> at
> org.apache.beam.runners.direct.DirectTransformExecutor.run(DirectTransformExecutor.java:124)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.Throwable: Code: 32, e.displayText() = DB::Exception:
> Attempt to read after eof: Cannot parse Int64 from String, because value is
> too short, e.what() = DB::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:53)
> ... 20 more
> ClickHouse exception, code: 999, host: localhost, port: 32840; Code: 999,
> e.displayText() = Coordination::Exception: All connection tries failed while
> connecting to ZooKeeper. Addresses: 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> (Connection loss), e.what() = Coordination::Exception
> ru.yandex.clickhouse.except.ClickHouseException: ClickHouse exception, code:
> 999, host: localhost, port: 32840; Code: 999, e.displayText() =
> Coordination::Exception: All connection tries failed while connecting to
> ZooKeeper. Addresses: 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> (Connection loss), e.what() = Coordination::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:58)
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:28)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.checkForErrorAndThrow(ClickHouseStatementImpl.java:766)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.getInputStream(ClickHouseStatementImpl.java:565)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.executeQuery(ClickHouseStatementImpl.java:117)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.executeQuery(ClickHouseStatementImpl.java:100)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.executeQuery(ClickHouseStatementImpl.java:95)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.executeQuery(ClickHouseStatementImpl.java:90)
> at
> ru.yandex.clickhouse.ClickHouseStatementImpl.execute(ClickHouseStatementImpl.java:191)
> at
> org.apache.beam.sdk.io.clickhouse.BaseClickHouseTest.executeSql(BaseClickHouseTest.java:141)
> at
> org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert(AtomicInsertTest.java:100)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:319)
> at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
> at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:365)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> at org.junit.runners.ParentRunner$4.run(ParentRunner.java:330)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:78)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:328)
> at org.junit.runners.ParentRunner.access$100(ParentRunner.java:65)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:412)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
> at
> org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
> at
> org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
> at
> org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
> at
> org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
> at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
> at
> org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:118)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
> at
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:175)
> at
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:157)
> at
> org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:404)
> at
> org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
> at
> org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at
> org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.Throwable: Code: 999, e.displayText() =
> Coordination::Exception: All connection tries failed while connecting to
> ZooKeeper. Addresses: 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> Poco::Exception. Code: 1000, e.code() = 0, e.displayText() = Timeout: connect
> timed out: 172.27.0.2:2181, e.what() = Timeout, 172.27.0.2:2181
> (Connection loss), e.what() = Coordination::Exception
> at
> ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify(ClickHouseExceptionSpecifier.java:53)
> ... 63 more
> {noformat}
>
> As I repeat this attemt, it seems that the IP address for the Zookeeper
> (172.27.0.2 in the case above) changes randomly.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
