2022-06-26 19:10:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/209566/0/logs.log
2022-06-26 19:10:40 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.format_type: does not have a value in the enumeration [Avro], $.compression_codec: string found, object expected, $.compression_codec: should be valid to one and only one of the schemas 
2022-06-26 19:10:40 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.flattening: is missing but it is required, $.format_type: does not have a value in the enumeration [CSV]
2022-06-26 19:10:40 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.format_type: does not have a value in the enumeration [JSONL]
2022-06-26 19:11:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/209566/0/logs.log
2022-06-26 19:10:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.3-alpha
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-salesforce-check-209566-0-clnjy for airbyte/source-salesforce:1.0.2
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubeProcessFactory(create):103 - source-salesforce-check-209566-0-clnjy stdoutLocalPort = 9014
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubeProcessFactory(create):106 - source-salesforce-check-209566-0-clnjy stderrLocalPort = 9015
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):583 - Creating stdout socket server...
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Creating stderr socket server...
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubePodProcess(<init>):515 - Creating pod source-salesforce-check-209566-0-clnjy...
2022-06-26 19:10:40 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-26 19:10:46 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/90ec115e-f4d4-4a33-84ce-3223d469b5ea/source_config.json de/source-salesforce-check-209566-0-clnjy:/config/source_config.json -c init
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/0ae82da8-b662-4788-b351-38de331a337a/FINISHED_UPLOADING de/source-salesforce-check-209566-0-clnjy:/config/FINISHED_UPLOADING -c init
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-26 19:10:48 [32mINFO[m i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-26 19:10:50 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):592 - Setting stdout...
2022-06-26 19:10:50 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):604 - Setting stderr...
2022-06-26 19:10:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):564 - Reading pod IP...
2022-06-26 19:10:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):566 - Pod IP: 10.10.132.16
2022-06-26 19:10:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):573 - Using null stdin output stream...
2022-06-26 19:10:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubePodProcess(close):713 - (pod: de / source-salesforce-check-209566-0-clnjy) - Closed all resources for pod
2022-06-26 19:11:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-26 19:11:03 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.3-alpha
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-s3-check-209566-0-kmvmw for airbyte/destination-s3:0.2.13
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubeProcessFactory(create):103 - destination-s3-check-209566-0-kmvmw stdoutLocalPort = 9022
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubeProcessFactory(create):106 - destination-s3-check-209566-0-kmvmw stderrLocalPort = 9023
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):583 - Creating stdout socket server...
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubePodProcess(<init>):515 - Creating pod destination-s3-check-209566-0-kmvmw...
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Creating stderr socket server...
2022-06-26 19:11:03 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/0214ff95-d640-495a-b184-070a467bd780/source_config.json de/destination-s3-check-209566-0-kmvmw:/config/source_config.json -c init
2022-06-26 19:11:15 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/7fa9bfb2-e8a4-4386-a608-2ca334f49898/FINISHED_UPLOADING de/destination-s3-check-209566-0-kmvmw:/config/FINISHED_UPLOADING -c init
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-26 19:11:16 [32mINFO[m i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-26 19:11:17 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):592 - Setting stdout...
2022-06-26 19:11:17 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):604 - Setting stderr...
2022-06-26 19:11:21 [32mINFO[m i.a.w.p.KubePodProcess(<init>):564 - Reading pod IP...
2022-06-26 19:11:21 [32mINFO[m i.a.w.p.KubePodProcess(<init>):566 - Pod IP: 10.10.134.170
2022-06-26 19:11:21 [32mINFO[m i.a.w.p.KubePodProcess(<init>):573 - Using null stdin output stream...
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.s3.S3Destination
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: CHECK
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [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-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [33mWARN[m 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-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [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-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"Parquet","page_size_kb":1024,"block_size_mb":128,"compression_codec":"UNCOMPRESSED","dictionary_encoding":true,"max_padding_size_mb":8,"dictionary_page_size_kb":1024}
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:18 [32mINFO[m i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):74 - Storage Object firebolt-production-data-lake/firebolt-production-data-lake does not exist in bucket; creating...
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):76 - Storage Object firebolt-production-data-lake/firebolt-production-data-lake has been created in bucket.
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3Destination(testIAMUserHasListObjectPermission):154 - Started testing if IAM user can call listObjects on the destination bucket
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3Destination(testIAMUserHasListObjectPermission):157 - Finished checking for listObjects permission
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3Destination(testSingleUpload):81 - Started testing if all required credentials assigned to user for single file uploading
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3Destination(testSingleUpload):88 - Finished checking for normal upload mode
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.S3Destination(testMultipartUpload):92 - Started testing if all required credentials assigned to user for multipart upload
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 5 MB
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to firebolt-production-data-lake/test_1656270679575 with full ID GFQ3OM6Hw6g2kL2BlDAWo57XNhrNj2tNt_HpdhsrfK3J4ng3iz7b8EL_5aZ3Whjo64rJ6SO62B8Vu6.4oN0UQvgSTAOSLegSD.xq.wKTNw4pFQSuSbbwJHfXQzrNfxPm
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [33mWARN[m a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m a.m.s.StreamTransferManager(complete):367 - [Manager uploading to firebolt-production-data-lake/test_1656270679575 with id GFQ3OM6Hw...XQzrNfxPm]: Uploading leftover stream [Part number 1 containing 3.34 MB]
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:19 [32mINFO[m a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to firebolt-production-data-lake/test_1656270679575 with id GFQ3OM6Hw...XQzrNfxPm]: Finished uploading [Part number 1 containing 3.34 MB]
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:20 [32mINFO[m a.m.s.StreamTransferManager(complete):395 - [Manager uploading to firebolt-production-data-lake/test_1656270679575 with id GFQ3OM6Hw...XQzrNfxPm]: Completed
2022-06-26 19:11:21 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-26 19:11:20 [32mINFO[m i.a.i.d.s.S3Destination(testMultipartUpload):118 - Finished verification for multipart upload mode
2022-06-26 19:11:21 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-06-26 19:11:21 [1;31mERROR[m 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-26 19:11:21 [1;31mERROR[m 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-26 19:11:21 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-26 19:11:21 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-26 19:11:28 [32mINFO[m i.a.w.p.KubePodProcess(close):713 - (pod: de / destination-s3-check-209566-0-kmvmw) - Closed all resources for pod
2022-06-26 19:11:28 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-26 19:11:38 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999970679s. [closed=[], open=[[remote_addr=airbyte-temporal-svc/100.69.93.195:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:2746) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:278) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:44) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:41) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:272) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:208) ~[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) [?:?]
2022-06-26 19:11:48 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999973080s. [closed=[], open=[[remote_addr=airbyte-temporal-svc/100.69.93.195:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:2746) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:278) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:44) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:41) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:272) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:208) ~[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) [?:?]
2022-06-26 19:11:58 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999974220s. [closed=[], open=[[remote_addr=airbyte-temporal-svc/100.69.93.195:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:2746) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:278) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:44) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:41) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:272) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:208) ~[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) [?:?]
2022-06-26 19:12:09 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999975149s. [closed=[], open=[[remote_addr=airbyte-temporal-svc/100.69.93.195:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:2746) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:278) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:44) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:41) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:272) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:208) ~[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) [?:?]
2022-06-26 19:12:19 [33mWARN[m i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999931988s. [closed=[], open=[[buffered_nanos=4134299, remote_addr=airbyte-temporal-svc/100.69.93.195:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:2746) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:278) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:44) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:41) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:272) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:208) ~[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) [?:?]