2022-04-20 13:38:10 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.30-alpha
2022-04-20 13:38:11 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/65/2/logs.log
2022-04-20 13:38:11 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.30-alpha
2022-04-20 13:38:11 [32mINFO[m i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 65 attempt id: 2
2022-04-20 13:38:11 [32mINFO[m i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.tickets=incremental - append_dedup, null.sla_policies=full_refresh - append, null.brands=full_refresh - append, null.ticket_fields=incremental - append_dedup, null.ticket_metric_events=incremental - append_dedup, null.ticket_metrics=incremental - append_dedup, null.tags=full_refresh - append}
2022-04-20 13:38:11 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-20 13:38:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.28 exists...
2022-04-20 13:38:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.28 was found locally.
2022-04-20 13:38:12 [32mINFO[m i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/65/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-redshift:0.3.28 write --config destination_config.json --catalog destination_catalog.json
2022-04-20 13:38:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-zendesk-support:0.2.5 exists...
2022-04-20 13:38:14 [32mINFO[m i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/65/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-zendesk-support:0.2.5 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-20 13:38:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-zendesk-support:0.2.5 was found locally.
2022-04-20 13:38:14 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):337 - Destination output thread started.
2022-04-20 13:38:14 [32mINFO[m i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-04-20 13:38:14 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-04-20 13:38:24 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-20 13:38:24 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-20 13:38:24 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-20 13:38:24 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-20 13:38:26 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-20 13:38:32 [44msource[0m > Starting syncing SourceZendeskSupport
2022-04-20 13:38:32 [44msource[0m > Syncing stream: brands 
2022-04-20 13:38:33 [44msource[0m > Read 12 records from brands stream
2022-04-20 13:38:33 [44msource[0m > Finished syncing brands
2022-04-20 13:38:33 [44msource[0m > SourceZendeskSupport runtimes:
Syncing stream brands 0:00:00.642016
2022-04-20 13:38:33 [44msource[0m > Syncing stream: sla_policies 
2022-04-20 13:38:33 [44msource[0m > Read 11 records from sla_policies stream
2022-04-20 13:38:33 [44msource[0m > Finished syncing sla_policies
2022-04-20 13:38:33 [44msource[0m > SourceZendeskSupport runtimes:
Syncing stream brands 0:00:00.642016
Syncing stream sla_policies 0:00:00.604080
2022-04-20 13:38:33 [44msource[0m > Syncing stream: tags 
2022-04-20 13:38:34 [44msource[0m > Read 199 records from tags stream
2022-04-20 13:38:34 [44msource[0m > Finished syncing tags
2022-04-20 13:38:34 [44msource[0m > SourceZendeskSupport runtimes:
Syncing stream brands 0:00:00.642016
Syncing stream sla_policies 0:00:00.604080
Syncing stream tags 0:00:01.112996
2022-04-20 13:38:34 [44msource[0m > Syncing stream: ticket_fields 
2022-04-20 13:38:35 [44msource[0m > Read 0 records from ticket_fields stream
2022-04-20 13:38:35 [44msource[0m > Finished syncing ticket_fields
2022-04-20 13:38:35 [44msource[0m > SourceZendeskSupport runtimes:
Syncing stream brands 0:00:00.642016
Syncing stream sla_policies 0:00:00.604080
Syncing stream tags 0:00:01.112996
Syncing stream ticket_fields 0:00:00.549230
2022-04-20 13:38:35 [44msource[0m > Syncing stream: ticket_metric_events 
2022-04-20 13:38:37 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 1000
2022-04-20 13:38:45 [43mdestination[0m > 2022-04-20 13:38:45 [32mINFO[m i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-20 13:38:48 [43mdestination[0m > 2022-04-20 13:38:48 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-20 13:38:48 [43mdestination[0m > 2022-04-20 13:38:48 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-20 13:38:48 [43mdestination[0m > 2022-04-20 13:38:48 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-20 13:38:49 [43mdestination[0m > 2022-04-20 13:38:48 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-20 13:38:53 [43mdestination[0m > 2022-04-20 13:38:53 [33mWARN[m 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-04-20 13:38:53 [43mdestination[0m > 2022-04-20 13:38:53 [33mWARN[m 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-04-20 13:38:54 [43mdestination[0m > 2022-04-20 13:38:54 [32mINFO[m i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3
2022-04-20 13:38:58 [43mdestination[0m > 2022-04-20 13:38:58 [32mINFO[m i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-04-20 13:39:13 [43mdestination[0m > 2022-04-20 13:39:13 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-20 13:39:16 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 2000
2022-04-20 13:39:18 [44msource[0m > Read 2480 records from ticket_metric_events stream
2022-04-20 13:39:18 [44msource[0m > Finished syncing ticket_metric_events
2022-04-20 13:39:18 [44msource[0m > SourceZendeskSupport runtimes:
Syncing stream brands 0:00:00.642016
Syncing stream sla_policies 0:00:00.604080
Syncing stream tags 0:00:01.112996
Syncing stream ticket_fields 0:00:00.549230
Syncing stream ticket_metric_events 0:00:04.845209
2022-04-20 13:39:18 [44msource[0m > Syncing stream: ticket_metrics 
2022-04-20 13:39:39 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 3000
2022-04-20 13:39:51 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 4000
2022-04-20 13:40:03 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 5000
2022-04-20 13:40:09 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 6000
2022-04-20 13:40:11 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 7000
2022-04-20 13:40:13 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 8000
2022-04-20 13:40:15 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 9000
2022-04-20 13:40:16 [43mdestination[0m > 2022-04-20 13:40:16 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 26213011 bytes
2022-04-20 13:40:16 [43mdestination[0m > 2022-04-20 13:40:16 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing brands: 12 records
2022-04-20 13:40:16 [43mdestination[0m > 2022-04-20 13:40:16 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-04-20 13:40:16 [43mdestination[0m > 2022-04-20 13:40:16 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'brands': s3://travlrdatatesting/airbyte_data/brands/2022_04_20_1650461951222_adb365c3-5955-4dd1-a17f-8489aa49f075.csv
2022-04-20 13:40:16 [43mdestination[0m > 2022-04-20 13:40:16 [32mINFO[m i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_data/brands/2022_04_20_1650461951222_adb365c3-5955-4dd1-a17f-8489aa49f075.csv with full ID XjDG96YjLSdNF3y1rDTsU0gXS9BzE2ePXUiNh.RggVOESjzFaNOu4vQ3ryaLAL8JQpS7rB9Ntkz0t54.UkgmWQUmTdBtTAz7kfepouqQdZeW8TiuvamQKZxxjsu8xrAtxzzBMAO75tSpUrZ25bjU6Q--
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing sla_policies: 11 records
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'sla_policies': s3://travlrdatatesting/airbyte_data/sla_policies/2022_04_20_1650461951318_2e1e15d6-cd2c-4315-91db-e9dc7c544c26.csv
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_data/sla_policies/2022_04_20_1650461951318_2e1e15d6-cd2c-4315-91db-e9dc7c544c26.csv with full ID VdKva949JClKTNciUIyA.YOw7bvSNrN33mt5z7CGxqvfKG12Qfvpv9kjAhcmwPq3N6Ce4xGih8JWI7lLy2K.lmj0IiGcDYMMUfSYYSo1h.WfAzM0ZduYEVuKFYqxBbW3RqRA5v4stuij.1P.bQIIhw--
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing ticket_metrics: 6723 records
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metrics': s3://travlrdatatesting/airbyte_data/ticket_metrics/2022_04_20_1650461951347_453342e1-780a-4622-82fe-039c5b3a9e84.csv
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-20 13:40:18 [43mdestination[0m > 2022-04-20 13:40:18 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_data/ticket_metrics/2022_04_20_1650461951347_453342e1-780a-4622-82fe-039c5b3a9e84.csv with full ID qpdprO04BU8ki6uxNwaNlInO_J.O8IhoO_3fNVUBxAJUVT21qOnNhTHbhY78VteL3iLpUfKRlWrQLgYV.kEyS2.sSUTr1HZe4MvSfVOM4G.ju4DM3440ZYGRIi5oYqnU5afe_vTm3S2YB4B9LzSR3A--
2022-04-20 13:40:20 [43mdestination[0m > 2022-04-20 13:40:20 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing ticket_metric_events: 2480 records
2022-04-20 13:40:20 [43mdestination[0m > 2022-04-20 13:40:20 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-04-20 13:40:20 [43mdestination[0m > 2022-04-20 13:40:20 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metric_events': s3://travlrdatatesting/airbyte_data/ticket_metric_events/2022_04_20_1650461951346_ac58b350-366e-4bb4-8943-9711bd074b8b.csv
2022-04-20 13:40:20 [43mdestination[0m > 2022-04-20 13:40:20 [32mINFO[m i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-20 13:40:20 [43mdestination[0m > 2022-04-20 13:40:20 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_data/ticket_metric_events/2022_04_20_1650461951346_ac58b350-366e-4bb4-8943-9711bd074b8b.csv with full ID 0tRuhCii9YhYlEv7aPfVRn3jQhiESVqVE.HofYlsB3T12fdJfy06uTCQxifQ_8IqimTwrGKI31qnBS0JY_2nrYJrKBBoTgVxqRHe6359i_3oADXEyQgDiTckJeeuzwbJzSI6lWQcPWZUZnI6xw3BeA--
2022-04-20 13:40:21 [43mdestination[0m > 2022-04-20 13:40:21 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing tags: 199 records
2022-04-20 13:40:21 [43mdestination[0m > 2022-04-20 13:40:21 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-04-20 13:40:21 [43mdestination[0m > 2022-04-20 13:40:21 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'tags': s3://travlrdatatesting/airbyte_data/tags/2022_04_20_1650461951330_a0c950cb-0e7a-4468-ac5b-2b4b73274c6a.csv
2022-04-20 13:40:21 [43mdestination[0m > 2022-04-20 13:40:21 [32mINFO[m i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-20 13:40:21 [43mdestination[0m > 2022-04-20 13:40:21 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_data/tags/2022_04_20_1650461951330_a0c950cb-0e7a-4468-ac5b-2b4b73274c6a.csv with full ID zxxfXY.aOQMiMXzGdETUVxa9o10jGd2i_VeEs6x1SSBvi6pZX.MfKKqT0bO2T8JuhXsMCUIwV86BIFc7beqJKVAmHWVNQMgJhIwen.Hi8wJQYEbAZl1fRcfxAjXnzNt9GTdsM_Ka9vMBXJHou8mm4A--
2022-04-20 13:40:21 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 10000
2022-04-20 13:40:21 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 11000
2022-04-20 13:40:23 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 12000
2022-04-20 13:40:24 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 13000
2022-04-20 13:40:26 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 14000
2022-04-20 13:40:28 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 15000
2022-04-20 13:40:30 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 16000
2022-04-20 13:40:32 [43mdestination[0m > 2022-04-20 13:40:32 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 26211415 bytes
2022-04-20 13:40:32 [43mdestination[0m > 2022-04-20 13:40:32 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing ticket_metrics: 7198 records
2022-04-20 13:40:33 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 17000
2022-04-20 14:41:46 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 69.999895095s. [closed=[], open=[[remote_addr=airbyte-temporal/172.22.0.5:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.6.0.jar:?]
	at jdk.proxy2.$Proxy45.run(Unknown Source) ~[?:?]
	at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:148) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:439) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:147) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:83) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.35.30-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.35.30-alpha.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	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) [?:?]
2022-04-20 14:47:46 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 69.992104740s. [closed=[], open=[[buffered_nanos=37952963, remote_addr=airbyte-temporal/172.22.0.5:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.6.0.jar:?]
	at jdk.proxy2.$Proxy45.run(Unknown Source) ~[?:?]
	at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:148) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:439) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:147) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:83) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.35.30-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.35.30-alpha.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	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) [?:?]
2022-04-20 14:47:52 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation...
2022-04-20 14:47:52 [32mINFO[m i.a.w.DefaultReplicationWorker(cancel):375 - Cancelling replication worker...
2022-04-20 14:48:02 [32mINFO[m i.a.w.DefaultReplicationWorker(cancel):383 - Cancelling destination...
2022-04-20 14:48:02 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-04-20 14:48:02 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-04-20 14:48:02 [32mINFO[m i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-04-20 14:48:02 [33mWARN[m i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-04-20 14:48:02 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-04-20 14:48:02 [32mINFO[m i.a.w.DefaultReplicationWorker(cancel):390 - Cancelling source...
2022-04-20 14:48:02 [32mINFO[m i.a.w.p.a.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-04-20 14:48:02 [32mINFO[m i.a.w.p.a.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-04-20 14:48:03 [32mINFO[m i.a.w.p.a.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-04-20 14:48:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread...
2022-04-20 14:48:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future...
2022-04-20 14:48:03 [33mWARN[m i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled.
2022-04-20 14:48:03 [33mWARN[m i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled.
2022-04-20 14:48:03 [32mINFO[m i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete.
2022-04-20 14:48:03 [1;31mERROR[m i.a.w.DefaultReplicationWorker(run):168 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:166) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.30-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.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-20 14:48:03 [32mINFO[m i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1930df3d[status=cancelled,recordsSynced=17454,bytesSynced=13863963,startTime=1650461891991,endTime=1650466083681,totalStats=io.airbyte.config.SyncStats@2e7ca8b5[recordsEmitted=17454,bytesEmitted=13863963,stateMessagesEmitted=2,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@3280adf0[streamName=brands,stats=io.airbyte.config.SyncStats@751aa085[recordsEmitted=12,bytesEmitted=20589,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@6acc502c[streamName=ticket_metrics,stats=io.airbyte.config.SyncStats@21be64c0[recordsEmitted=14752,bytesEmitted=13440290,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@1666a22a[streamName=sla_policies,stats=io.airbyte.config.SyncStats@36d836eb[recordsEmitted=11,bytesEmitted=26555,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@3e9d5d2c[streamName=ticket_metric_events,stats=io.airbyte.config.SyncStats@6cd7b65b[recordsEmitted=2480,bytesEmitted=370376,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4f833e19[streamName=tags,stats=io.airbyte.config.SyncStats@389b366c[recordsEmitted=199,bytesEmitted=6153,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-20 14:48:03 [32mINFO[m i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-04-20 14:48:03 [33mWARN[m i.a.w.DefaultReplicationWorker(run):257 - State capture: No new state, falling back on input state: io.airbyte.config.State@6cbb786e[state={"ticket_fields":{"updated_at":"2022-04-14T06:20:39Z"},"ticket_metric_events":{"time":"2022-04-19T15:29:31Z"}}]
2022-04-20 14:48:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-20 14:48:03 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):234 - Stopping temporal heartbeating...
2022-04-20 14:48:03 [33mWARN[m i.t.i.s.POJOActivityTaskHandler(activityFailureToResult):363 - Activity failure. ActivityId=48ae607c-1d59-309f-ad8f-e06feb723d73, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:232) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:104) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor179.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.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:286) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:252) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:209) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:193) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:151) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.6.0.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:201) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:53) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.35.30-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