2022-06-23 01:00:39 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/048c8cf6-3a20-495e-ab4b-4898f28659d6/0/logs.log 2022-06-23 01:00:39 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.20-alpha 2022-06-23 01:00:39 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-cassandra:0.1.2 exists... 2022-06-23 01:00:39 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-cassandra:0.1.2 was found locally. 2022-06-23 01:00:39 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 048c8cf6-3a20-495e-ab4b-4898f28659d6 2022-06-23 01:00:39 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/048c8cf6-3a20-495e-ab4b-4898f28659d6/0 --log-driver none --name destination-cassandra-check-048c8cf6-3a20-495e-ab4b-4898f28659d6-0-zaqol --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-cassandra:0.1.2 -e AIRBYTE_VERSION=0.39.20-alpha -e WORKER_JOB_ID=048c8cf6-3a20-495e-ab4b-4898f28659d6 airbyte/destination-cassandra:0.1.2 check --config source_config.json 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.cassandra.CassandraDestination 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-23 01:00:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:40 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-23 01:00:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:41 INFO c.d.o.d.i.c.DefaultMavenCoordinates(buildFromResourceAndPrint):37 - DataStax Java driver for Apache Cassandra(R) (com.datastax.oss:java-driver-core) version 4.13.0 2022-06-23 01:00:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:41 INFO c.d.o.d.i.c.t.Clock(getInstance):47 - Using native clock for microsecond precision 2022-06-23 01:00:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:48 WARN c.d.o.d.i.c.u.Loggers(warnWithException):39 - [s0|/10.20.2.84:9042] Error while opening new channel (DriverTimeoutException: [s0|id: 0x4ef43a08, L:/10.20.2.72:36414 - R:/10.20.2.84:9042] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.13.0, CLIENT_ID=ddb94e49-4dd0-4325-937b-1c21cca8088b}): timed out after 5000 ms) 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:50 ERROR i.a.i.d.c.CassandraDestination(check):43 - Can't establish Cassandra connection with reason: 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - com.datastax.oss.driver.api.core.DriverTimeoutException: Query timed out after PT2S 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.api.core.DriverTimeoutException.copy(DriverTimeoutException.java:34) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:149) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:53) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:30) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.session.DefaultSession.execute(DefaultSession.java:230) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.api.core.cql.SyncCqlSession.execute(SyncCqlSession.java:54) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraCqlProvider.createTableIfNotExists(CassandraCqlProvider.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraDestination.check(CassandraDestination.java:39) [io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:140) [io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) [io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-06-23 01:00:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraDestination.main(CassandraDestination.java:25) [io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:52 ERROR i.a.i.d.c.CassandraDestination(check):50 - Error while deleting temp table table_39ca449952f64a3caa5609a003daee8f with reason: 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - com.datastax.oss.driver.api.core.DriverTimeoutException: Query timed out after PT2S 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.api.core.DriverTimeoutException.copy(DriverTimeoutException.java:34) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:149) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:53) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:30) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.internal.core.session.DefaultSession.execute(DefaultSession.java:230) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.datastax.oss.driver.api.core.cql.SyncCqlSession.execute(SyncCqlSession.java:54) ~[java-driver-core-4.13.0.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraCqlProvider.dropTableIfExists(CassandraCqlProvider.java:82) ~[io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraDestination.check(CassandraDestination.java:48) [io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:140) [io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) [io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.cassandra.CassandraDestination.main(CassandraDestination.java:25) [io.airbyte.airbyte-integrations.connectors-destination-cassandra-0.39.20-alpha.jar:?] 2022-06-23 01:00:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-23 01:00:52 WARN c.d.o.d.i.c.u.Loggers(warnWithException):39 - [s0|/10.20.2.84:9042] Error while opening new channel (ConnectionInitException: [s0|id: 0x11c169eb, L:/10.20.2.72:36676 - R:/10.20.2.84:9042] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.13.0, CLIENT_ID=ddb94e49-4dd0-4325-937b-1c21cca8088b}): unexpected failure (com.datastax.oss.driver.api.core.connection.ClosedConnectionException: Lost connection to remote peer)) 2022-06-23 01:00:55 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...