2022-08-16 14:00:46 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/858/0/logs.log
2022-08-16 14:00:46 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.23-alpha
2022-08-16 14:00:46 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-ads:0.1.44 exists...
2022-08-16 14:00:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-ads:0.1.44 was found locally.
2022-08-16 14:00:46 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 858
2022-08-16 14:00:46 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/858/0 --log-driver none --name source-google-ads-check-858-0-ngkhd --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/source-google-ads:0.1.44 -e AIRBYTE_VERSION=0.39.23-alpha -e WORKER_JOB_ID=858 airbyte/source-google-ads:0.1.44 check --config source_config.json
2022-08-16 14:00:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Checking the config
2022-08-16 14:01:01 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-08-16 14:01:01 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-16 14:01:01 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/858/0/logs.log
2022-08-16 14:01:01 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.23-alpha
2022-08-16 14:01:01 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mssql:0.1.20 exists...
2022-08-16 14:01:01 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mssql:0.1.20 was found locally.
2022-08-16 14:01:01 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 858
2022-08-16 14:01:01 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/858/0 --log-driver none --name destination-mssql-check-858-0-btpbz --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-mssql:0.1.20 -e AIRBYTE_VERSION=0.39.23-alpha -e WORKER_JOB_ID=858 airbyte/destination-mssql:0.1.20 check --config source_config.json
2022-08-16 14:01:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-08-16 14:01:02 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-08-16 14:01:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-16 14:01:02 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-08-16 14:01:02 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-08-16 14:01:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-16 14:01:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.d.m.MSSQLDestination(main):104 - starting destination: class io.airbyte.integrations.destination.mssql.MSSQLDestination
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 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-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 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-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 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-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 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-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-16 14:01:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:03 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-16 14:01:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:04 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-16 14:01:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-16 14:01:04 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-16 14:01:04 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-16 14:01:04 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/858/0/logs.log
2022-08-16 14:01:04 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.23-alpha
2022-08-16 14:01:04 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 858 attempt id: 0
2022-08-16 14:01:04 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.shopping_performance_report=incremental - append}
2022-08-16 14:01:04 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-16 14:01:04 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mssql:0.1.20 exists...
2022-08-16 14:01:05 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mssql:0.1.20 was found locally.
2022-08-16 14:01:05 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 858
2022-08-16 14:01:05 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/858/0 --log-driver none --name destination-mssql-write-858-0-vjpvq --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-mssql:0.1.20 -e AIRBYTE_VERSION=0.39.23-alpha -e WORKER_JOB_ID=858 airbyte/destination-mssql:0.1.20 write --config destination_config.json --catalog destination_catalog.json
2022-08-16 14:01:05 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-ads:0.1.44 exists...
2022-08-16 14:01:05 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-ads:0.1.44 was found locally.
2022-08-16 14:01:05 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 858
2022-08-16 14:01:05 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/858/0 --log-driver none --name source-google-ads-read-858-0-bbthq --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/source-google-ads:0.1.44 -e AIRBYTE_VERSION=0.39.23-alpha -e WORKER_JOB_ID=858 airbyte/source-google-ads:0.1.44 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-08-16 14:01:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-08-16 14:01:05 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-08-16 14:01:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-08-16 14:01:05 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-08-16 14:01:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-16 14:01:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-16 14:01:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-16 14:01:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-16 14:01:05 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-16 14:01:06 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-16 14:01:06 source > Starting syncing SourceGoogleAds
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.d.m.MSSQLDestination(main):104 - starting destination: class io.airbyte.integrations.destination.mssql.MSSQLDestination
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-16 14:01:07 destination > 2022-08-16 14:01:07 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-08-16 14:01:07 destination > 2022-08-16 14:01:07 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-08-16 14:01:07 destination > 2022-08-16 14:01:07 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-08-16 14:01:07 destination > 2022-08-16 14:01:07 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-08-16 14:01:07 destination > 2022-08-16 14:01:07 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=evomcc_shopping_performance_report, namespace=google_ads, outputSchemaName=google_ads, tmpTableName=_airbyte_tmp_ets_evomcc_shopping_performance_report, outputTableName=_airbyte_raw_evomcc_shopping_performance_report, syncMode=append}
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream evomcc_shopping_performance_report. schema: google_ads, tmp table name: _airbyte_tmp_ets_evomcc_shopping_performance_report
2022-08-16 14:01:08 destination > 2022-08-16 14:01:08 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed.
2022-08-16 14:01:14 source > Syncing stream: shopping_performance_report 
2022-08-16 14:01:14 source > Setting state of shopping_performance_report stream to {'3927017757': {'segments.date': '2022-08-15'}}
2022-08-16 14:11:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 1000 (2 MB)
2022-08-16 14:11:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 2000 (4 MB)
2022-08-16 14:11:20 destination > 2022-08-16 14:11:20 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2742 records (24 MB)
2022-08-16 14:11:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 3000 (6 MB)
2022-08-16 14:11:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 4000 (9 MB)
2022-08-16 14:11:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 5000 (11 MB)
2022-08-16 14:11:32 destination > 2022-08-16 14:11:32 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2721 records (24 MB)
2022-08-16 14:11:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 6000 (13 MB)
2022-08-16 14:11:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 7000 (15 MB)
2022-08-16 14:11:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 8000 (18 MB)
2022-08-16 14:11:44 destination > 2022-08-16 14:11:44 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2732 records (24 MB)
2022-08-16 14:11:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 9000 (20 MB)
2022-08-16 14:11:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 10000 (22 MB)
2022-08-16 14:11:55 destination > 2022-08-16 14:11:55 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2744 records (24 MB)
2022-08-16 14:11:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 11000 (25 MB)
2022-08-16 14:12:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 12000 (27 MB)
2022-08-16 14:12:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 13000 (29 MB)
2022-08-16 14:12:08 destination > 2022-08-16 14:12:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2763 records (24 MB)
2022-08-16 14:12:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 14000 (31 MB)
2022-08-16 14:12:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 15000 (34 MB)
2022-08-16 14:12:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 16000 (36 MB)
2022-08-16 14:12:21 destination > 2022-08-16 14:12:21 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2723 records (24 MB)
2022-08-16 14:12:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 17000 (38 MB)
2022-08-16 14:12:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 18000 (41 MB)
2022-08-16 14:12:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 19000 (43 MB)
2022-08-16 14:12:34 destination > 2022-08-16 14:12:34 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2689 records (24 MB)
2022-08-16 14:12:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 20000 (45 MB)
2022-08-16 14:12:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 21000 (48 MB)
2022-08-16 14:12:48 destination > 2022-08-16 14:12:48 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2763 records (24 MB)
2022-08-16 14:12:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 22000 (50 MB)
2022-08-16 14:12:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 23000 (52 MB)
2022-08-16 14:13:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 24000 (54 MB)
2022-08-16 14:13:03 destination > 2022-08-16 14:13:03 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing evomcc_shopping_performance_report: 2725 records (24 MB)
2022-08-16 14:13:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 25000 (57 MB)
2022-08-16 21:51:14 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation...
2022-08-16 21:51:14 INFO i.a.w.g.DefaultReplicationWorker(cancel):443 - Cancelling replication worker...
2022-08-16 21:51:24 INFO i.a.w.g.DefaultReplicationWorker(cancel):451 - Cancelling destination...
2022-08-16 21:51:24 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-08-16 21:51:24 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-08-16 21:51:24 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-08-16 21:51:24 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-08-16 21:51:24 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-08-16 21:51:24 INFO i.a.w.g.DefaultReplicationWorker(cancel):458 - Cancelling source...
2022-08-16 21:51:24 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-08-16 21:51:24 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-08-16 21:51:25 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-08-16 21:51:25 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread...
2022-08-16 21:51:25 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-08-16 21:51:25 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future...
2022-08-16 21:51:25 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-08-16 21:51:25 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-16 21:51:25 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-08-16 21:51:25 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-08-16 21:51:25 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. 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.23-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) ~[?:?]
		at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:320) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-08-16 21:51:25 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=b46aaee8-683a-375d-bfe5-35d99077540b, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:111) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor428.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.23-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.23-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:207) ~[io.airbyte-airbyte-workers-0.39.23-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-08-16 21:51:25 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4defd9f8[status=cancelled,recordsSynced=25343,bytesSynced=60750797,startTime=1660658464965,endTime=1660686685232,totalStats=io.airbyte.config.SyncStats@1751df15[recordsEmitted=25343,bytesEmitted=60750797,stateMessagesEmitted=12,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@fa608d4[streamName=evomcc_shopping_performance_report,stats=io.airbyte.config.SyncStats@7d2b044b[recordsEmitted=25343,bytesEmitted=60750797,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-08-16 21:51:25 INFO i.a.w.g.DefaultReplicationWorker(run):266 - Source output at least one state message
2022-08-16 21:51:25 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@4eb8320f[state={"shopping_performance_report":{"3927017757":{"segments.date":"2022-08-15"}}}]