2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.encryption: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Standard] 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.encryption: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Internal Staging] 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.access_key_id: object found, string expected, $.secret_access_key: object found, string expected 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.project_id: is missing but it is required, $.bucket_name: is missing but it is required, $.credentials_json: is missing but it is required, $.part_size: is not defined in the schema and the schema does not allow additional properties, $.encryption: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [GCS Staging] 2022-06-06 20:29:28 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.azure_blob_storage_account_name: is missing but it is required, $.azure_blob_storage_container_name: is missing but it is required, $.azure_blob_storage_sas_token: is missing but it is required, $.part_size: is not defined in the schema and the schema does not allow additional properties, $.encryption: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Azure Blob Staging] 2022-06-06 20:29:28 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/25581/0/logs.log 2022-06-06 20:29:28 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.10-alpha 2022-06-06 20:29:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.11 exists... 2022-06-06 20:29:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.11 was found locally. 2022-06-06 20:29:28 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 25581 2022-06-06 20:29:28 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25581/0 --log-driver none --name source-mysql-check-25581-0-idcvu --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.11 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.10-alpha -e WORKER_JOB_ID=25581 airbyte/source-mysql:0.5.11 check --config source_config.json 2022-06-06 20:29:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-06-06 20:29:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-06 20:29:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.s.m.MySqlSource(main):210 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: CHECK 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 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-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 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-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 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-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-06 20:29:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:32 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-06-06 20:29:33 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:33 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):89 - Attempting to get metadata from the database to see if we can connect. 2022-06-06 20:29:34 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-06 20:29:34 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/25581/0/logs.log 2022-06-06 20:29:34 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.10-alpha 2022-06-06 20:29:34 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.28 exists... 2022-06-06 20:29:34 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.28 was found locally. 2022-06-06 20:29:34 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 25581 2022-06-06 20:29:34 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25581/0 --log-driver none --name destination-snowflake-check-25581-0-bjnqq --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.28 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.10-alpha -e WORKER_JOB_ID=25581 airbyte/destination-snowflake:0.4.28 check --config source_config.json 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-06 20:29:37 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 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-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 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-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 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-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: COPY_S3 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):166 - Creating S3 client... 2022-06-06 20:29:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:38 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-06-06 20:29:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:40 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@483f286e 2022-06-06 20:29:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:40 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-06-06 20:29:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:41 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-06-06 20:29:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:42 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):97 - Storage Object mybucket/_ANALYTICS__AIRBYTE_CONNECTION_TEST_97C6816E_3424_4834_8946_C59D8423F956 does not exist in bucket; creating... 2022-06-06 20:29:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:42 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):99 - Storage Object mybucket/_ANALYTICS__AIRBYTE_CONNECTION_TEST_97C6816E_3424_4834_8946_C59D8423F956 has been created in bucket. 2022-06-06 20:29:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:42 INFO i.a.i.d.s.S3StorageOperations(cleanUpObjects):281 - Deleting objects _ANALYTICS__AIRBYTE_CONNECTION_TEST_97C6816E_3424_4834_8946_C59D8423F956/ 2022-06-06 20:29:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:42 INFO i.a.i.d.s.S3StorageOperations(cleanUpBucketObject):270 - Storage bucket _ANALYTICS__AIRBYTE_CONNECTION_TEST_97C6816E_3424_4834_8946_C59D8423F956 has been cleaned-up (1 objects were deleted)... 2022-06-06 20:29:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:42 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-06-06 20:29:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-06 20:29:43 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-06-06 20:29:45 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-06 20:29:46 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/25581/0/logs.log 2022-06-06 20:29:46 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.10-alpha 2022-06-06 20:29:46 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 25581 attempt id: 0 2022-06-06 20:29:46 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {mydb.mytable=incremental - append_dedup} 2022-06-06 20:29:46 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-06-06 20:29:46 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.28 exists... 2022-06-06 20:29:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.28 was found locally. 2022-06-06 20:29:46 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 25581 2022-06-06 20:29:46 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25581/0 --log-driver none --name destination-snowflake-write-25581-0-dlblw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.28 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.10-alpha -e WORKER_JOB_ID=25581 airbyte/destination-snowflake:0.4.28 write --config destination_config.json --catalog destination_catalog.json 2022-06-06 20:29:46 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.11 exists... 2022-06-06 20:29:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.11 was found locally. 2022-06-06 20:29:46 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 25581 2022-06-06 20:29:46 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25581/0 --log-driver none --name source-mysql-read-25581-0-gnomh --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.11 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.10-alpha -e WORKER_JOB_ID=25581 airbyte/source-mysql:0.5.11 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-06-06 20:29:46 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete. 2022-06-06 20:29:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):395 - Destination output thread started. 2022-06-06 20:29:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started. 2022-06-06 20:29:49 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-06-06 20:29:49 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:49 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:49 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:49 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-06 20:29:49 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-06 20:29:49 source > SLF4J: Class path contains multiple SLF4J bindings. 2022-06-06 20:29:49 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:49 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-06 20:29:49 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-06 20:29:49 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 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-06 20:29:50 destination > 2022-06-06 20:29:50 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-06 20:29:50 destination > 2022-06-06 20:29:50 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-06 20:29:50 destination > 2022-06-06 20:29:50 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.s.m.MySqlSource(main):210 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):166 - Creating S3 client... 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 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-06 20:29:50 source > 2022-06-06 20:29:50 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-06 20:29:50 source > 2022-06-06 20:29:50 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-06 20:29:50 source > 2022-06-06 20:29:50 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=mytable, namespace=mydb, outputSchemaName=mydb, tmpTableName=tmp_table, outputTableName=_airbyte_raw_myable, syncMode=append_dedup} 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 1 streams 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema mydb stream mytable: tmp table: tmp_table, stage: MYDB_MYTABLE/2022/06/06/20/24A72B9F-D299-4B6F-9F93-650147B77B05/ 2022-06-06 20:29:50 destination > 2022-06-06 20:29:50 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-06-06 20:29:50 source > 2022-06-06 20:29:50 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null ... ... 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 1000 (479 KB) 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 2000 (959 KB) 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 3000 (1 MB) 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 4000 (1 MB) 2022-06-06 20:29:54 source > 2022-06-06 20:29:54 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 20000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:00.668 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 5000 (2 MB) 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 6000 (2 MB) 2022-06-06 20:29:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 7000 (3 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 8000 (3 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 9000 (4 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 10000 (4 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 11000 (5 MB) 2022-06-06 20:29:55 source > 2022-06-06 20:29:55 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 30000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:01.421 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 12000 (5 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 13000 (6 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 14000 (6 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 15000 (7 MB) 2022-06-06 20:29:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 16000 (7 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 17000 (7 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 18000 (8 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 19000 (8 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 20000 (9 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 21000 (9 MB) 2022-06-06 20:29:56 source > 2022-06-06 20:29:56 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 40000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:02.514 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 22000 (10 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 23000 (10 MB) 2022-06-06 20:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 24000 (11 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 25000 (11 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 26000 (12 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 27000 (12 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 28000 (13 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 29000 (13 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 30000 (14 MB) 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 31000 (14 MB) 2022-06-06 20:29:57 source > 2022-06-06 20:29:57 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 50000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:03.856 2022-06-06 20:29:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 32000 (15 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 33000 (15 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 34000 (15 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 35000 (16 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 36000 (16 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 37000 (17 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 38000 (17 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 39000 (18 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 40000 (18 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 41000 (19 MB) 2022-06-06 20:29:58 source > 2022-06-06 20:29:58 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 60000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:04.811 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 42000 (19 MB) 2022-06-06 20:29:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 43000 (20 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 44000 (20 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 45000 (21 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 46000 (21 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 47000 (22 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 48000 (22 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 49000 (23 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 50000 (23 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 51000 (23 MB) 2022-06-06 20:29:59 source > 2022-06-06 20:29:59 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 70000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:05.838 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 52000 (24 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 53000 (24 MB) 2022-06-06 20:29:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 54000 (25 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 55000 (25 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 56000 (26 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 57000 (26 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 58000 (27 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 59000 (27 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 60000 (28 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 61000 (28 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 62000 (29 MB) 2022-06-06 20:30:00 source > 2022-06-06 20:30:00 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 80000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:06.804 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 63000 (29 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 64000 (30 MB) 2022-06-06 20:30:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 65000 (30 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 66000 (31 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 67000 (31 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 68000 (31 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 69000 (32 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 70000 (32 MB) 2022-06-06 20:30:01 source > 2022-06-06 20:30:01 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 90000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:07.592 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 71000 (33 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 72000 (33 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 73000 (34 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 74000 (34 MB) 2022-06-06 20:30:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 75000 (35 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 76000 (35 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 77000 (36 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 78000 (36 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 79000 (37 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 80000 (37 MB) 2022-06-06 20:30:02 source > 2022-06-06 20:30:02 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 100000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:08.484 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 81000 (38 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 82000 (38 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 83000 (39 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 84000 (39 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 85000 (40 MB) 2022-06-06 20:30:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 86000 (40 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 87000 (40 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 88000 (41 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 89000 (41 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 90000 (42 MB) 2022-06-06 20:30:03 source > 2022-06-06 20:30:03 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 110000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:09.456 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 91000 (42 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 92000 (43 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 93000 (43 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 94000 (44 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 95000 (44 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 96000 (45 MB) 2022-06-06 20:30:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 97000 (45 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 98000 (46 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 99000 (46 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 100000 (47 MB) 2022-06-06 20:30:04 source > 2022-06-06 20:30:03 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 120000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:10.359 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 101000 (47 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 102000 (48 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 103000 (48 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 104000 (48 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 105000 (49 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 106000 (49 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 107000 (50 MB) 2022-06-06 20:30:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 108000 (50 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 109000 (51 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 110000 (51 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 111000 (52 MB) 2022-06-06 20:30:05 source > 2022-06-06 20:30:05 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 130000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:11.378 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 112000 (52 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 113000 (53 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 114000 (53 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 115000 (54 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 116000 (54 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 117000 (55 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 118000 (55 MB) 2022-06-06 20:30:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 119000 (56 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 120000 (56 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 121000 (57 MB) 2022-06-06 20:30:06 source > 2022-06-06 20:30:05 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 140000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:12.311 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 122000 (57 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 123000 (57 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 124000 (58 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 125000 (58 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 126000 (59 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 127000 (59 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 128000 (60 MB) 2022-06-06 20:30:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 129000 (60 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 130000 (61 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 131000 (61 MB) 2022-06-06 20:30:07 source > 2022-06-06 20:30:06 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 150000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:13.216 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 132000 (62 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 133000 (62 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 134000 (63 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 135000 (63 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 136000 (64 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 137000 (64 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 138000 (65 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 139000 (65 MB) 2022-06-06 20:30:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 140000 (65 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 141000 (66 MB) 2022-06-06 20:30:08 source > 2022-06-06 20:30:07 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 160000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:14.149 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 142000 (66 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 143000 (67 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 144000 (67 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 145000 (68 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 146000 (68 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 147000 (69 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 148000 (69 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 149000 (70 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 150000 (70 MB) 2022-06-06 20:30:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 151000 (71 MB) 2022-06-06 20:30:08 source > 2022-06-06 20:30:08 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 170000 of 117654782 rows scanned from table 'mydb.mytable' after 00:00:15.027 2022-06-06 20:30:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 152000 (71 MB) 2022-06-06 20:30:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 153000 (72 MB) 2022-06-06 20:30:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 154000 (72 MB) 2022-06-06 20:30:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 155000 (73 MB) 2022-06-06 20:30:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 156000 (73 MB) .... ... 2022-06-07 01:22:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 786000 (372 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 787000 (372 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 788000 (373 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 789000 (373 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 790000 (374 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 791000 (374 MB) 2022-06-07 01:22:47 source > 2022-06-07 01:22:47 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 810000 of 117657570 rows scanned from table 'mydb.mytable' after 00:01:19.197 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 792000 (375 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 793000 (375 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 794000 (375 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 795000 (376 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 796000 (376 MB) 2022-06-07 01:22:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 797000 (377 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 798000 (377 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 799000 (378 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 800000 (378 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 801000 (379 MB) 2022-06-07 01:22:48 source > 2022-06-07 01:22:48 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 820000 of 117657570 rows scanned from table 'mydb.mytable' after 00:01:20.132 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 802000 (379 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 803000 (380 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 804000 (380 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 805000 (381 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 806000 (381 MB) 2022-06-07 01:22:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 807000 (382 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 808000 (382 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 809000 (383 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 810000 (383 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 811000 (384 MB) 2022-06-07 01:22:49 source > 2022-06-07 01:22:49 INFO i.d.c.m.SnapshotReader(lambda$execute$16):677 - Step 7: - 830000 of 117657570 rows scanned from table 'mydb.mytable' after 00:01:21.082 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 812000 (384 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 813000 (385 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 814000 (385 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 815000 (385 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 816000 (386 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 817000 (386 MB) 2022-06-07 01:22:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):344 - Records read: 818000 (387 MB) 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):355 - Total records read: 818997 (387 MB) 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(cancel):441 - Cancelling destination... 2022-06-07 01:22:50 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):358 - Schema validation errors found for stream mytable. Error messages: [$.isdeleted is of an incorrect type. Expected it to be boolean, $._iswinner is of an incorrect type. Expected it to be boolean, $.iseliminated is of an incorrect type. Expected it to be boolean, $._ab_cdc_deleted_at is of an incorrect type. Expected it to be string] 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other. 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete. 2022-06-07 01:22:50 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(cancel):448 - Cancelling source... 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-06-07 01:22:50 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-06-07 01:22:50 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-06-07 01:22:50 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread... 2022-06-07 01:22:50 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future... 2022-06-07 01:22:50 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-06-07 01:22:50 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-07 01:22:50 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-06-07 01:22:50 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-06-07 01:22:50 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... ... 2022-06-07 01:22:50 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-06-07 01:22:50 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=5707d82d-66d4-3b54-b777-074d54ee465c, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:234) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:111) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at jdk.internal.reflect.GeneratedMethodAccessor476.invoke(Unknown Source) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:207) ~[io.airbyte-airbyte-workers-0.39.10-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-06-07 01:22:50 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@2442aa0e[state={}]