2023-02-01 19:00:25 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 2023-02-01 19:00:25 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 2023-02-01 19:00:25 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 2023-02-01 19:00:25 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 2023-02-01 19:00:25 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 2023-02-01 19:00:25 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.private_key: is missing but it is required 2023-02-01 19:00:25 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2023-02-01 19:00:25 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:00:25 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:00:26 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:00:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:00:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:00:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name source-mongodb-v2-check-27-0-zzqiw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 check --config source_config.json 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 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 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 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 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 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 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:00:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:28 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:00:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:43 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46495}] to mongo-prod.localcoin.local:27017 2023-02-01 19:00:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:43 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46496}] to mongo-prod.localcoin.local:27017 2023-02-01 19:00:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:43 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=116736376} 2023-02-01 19:00:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:44 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46497}] to mongo-prod.localcoin.local:27017 2023-02-01 19:00:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:44 INFO i.a.i.s.m.MongoDbSource(lambda$getCheckOperations$0):95 - The source passed the basic operation test! 2023-02-01 19:00:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:44 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:00:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:00:44 INFO i.a.i.s.m.MongoDbSource(main):65 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:00:44 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:00:54 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999247453s. [closed=[], open=[[buffered_nanos=9999820583, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:01:26 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:01:26 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:01:27 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:01:27 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:01:27 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:01:27 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name source-mongodb-v2-check-27-0-tukbf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 check --config source_config.json 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 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 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 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 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 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 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:01:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:30 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:01:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:45 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46499}] to mongo-prod.localcoin.local:27017 2023-02-01 19:01:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:45 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46498}] to mongo-prod.localcoin.local:27017 2023-02-01 19:01:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:45 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=185690403} 2023-02-01 19:01:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:46 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46500}] to mongo-prod.localcoin.local:27017 2023-02-01 19:01:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:46 INFO i.a.i.s.m.MongoDbSource(lambda$getCheckOperations$0):95 - The source passed the basic operation test! 2023-02-01 19:01:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:46 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:01:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:01:46 INFO i.a.i.s.m.MongoDbSource(main):65 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:01:46 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:01:56 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999623521s. [closed=[], open=[[buffered_nanos=10000043651, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:02:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:02:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:03:07 WARN i.t.i.a.HeartbeatContextImpl(doHeartBeatLocked):145 - Heartbeat failed io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999697309s. [closed=[], open=[[buffered_nanos=9999883606, waiting_for_connection]]] 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.recordActivityTaskHeartbeat(WorkflowServiceGrpc.java:2716) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.client.ActivityClientHelper.sendHeartbeatRequest(ActivityClientHelper.java:61) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.sendHeartbeatRequest(HeartbeatContextImpl.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.doHeartBeatLocked(HeartbeatContextImpl.java:139) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.heartbeat(HeartbeatContextImpl.java:108) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.ActivityExecutionContextImpl.heartbeat(ActivityExecutionContextImpl.java:93) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:50) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:122) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.check.connection.CheckConnectionActivityImpl.runWithJobOutput(CheckConnectionActivityImpl.java:79) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:03:07 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:03:08 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:03:08 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:03:08 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name source-mongodb-v2-check-27-0-cmpox --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 check --config source_config.json 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 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 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 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 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 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 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:09 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:03:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:24 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46501}] to mongo-prod.localcoin.local:27017 2023-02-01 19:03:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:24 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=106800340} 2023-02-01 19:03:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:24 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46502}] to mongo-prod.localcoin.local:27017 2023-02-01 19:03:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:25 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46503}] to mongo-prod.localcoin.local:27017 2023-02-01 19:03:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:25 INFO i.a.i.s.m.MongoDbSource(lambda$getCheckOperations$0):95 - The source passed the basic operation test! 2023-02-01 19:03:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:25 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:03:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:25 INFO i.a.i.s.m.MongoDbSource(main):65 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:03:25 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:03:25 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:03:25 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:03:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:03:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:03:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:03:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name destination-snowflake-check-27-0-mxztk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:03:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:03:27 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] 2023-02-01 19:03:27 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] 2023-02-01 19:03:27 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] 2023-02-01 19:03:27 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] 2023-02-01 19:03:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:03:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 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 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 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 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 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 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 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 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:28 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:03:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:39 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:03:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:39 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:03:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:40 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:03:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:41 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:03:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:42 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:03:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:03:42 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:03:42 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:03:52 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999673918s. [closed=[], open=[[buffered_nanos=10000013460, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:04:26 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:04:26 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:04:26 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:04:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:04:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:04:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name destination-snowflake-check-27-0-qlfel --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:04:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:04:27 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] 2023-02-01 19:04:27 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] 2023-02-01 19:04:27 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] 2023-02-01 19:04:27 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] 2023-02-01 19:04:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:04:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 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 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 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 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 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 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 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 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:04:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:28 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:04:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:40 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:04:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:40 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:04:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:40 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:04:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:41 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:04:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:41 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:04:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:04:41 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:04:42 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:04:52 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999544764s. [closed=[], open=[[buffered_nanos=9999816989, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:04:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/0/logs.log 2023-02-01 19:04:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:04:57 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 27 attempt id: 0 2023-02-01 19:04:57 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {coinatmradar.analytics=incremental - append_dedup} 2023-02-01 19:04:57 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2023-02-01 19:04:57 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:04:57 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:04:57 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:04:57 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name destination-snowflake-write-27-0-byoxx --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 write --config destination_config.json --catalog destination_catalog.json 2023-02-01 19:04:57 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:04:57 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:04:57 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:04:57 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/0 --log-driver none --name source-mongodb-v2-read-27-0-mxrjr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 read --config source_config.json --catalog source_catalog.json --state input_state.json 2023-02-01 19:04:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2023-02-01 19:04:57 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2023-02-01 19:04:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2023-02-01 19:04:58 destination > SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:04:58 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:04:58 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:04:58 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:04:58 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:04:58 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:04:58 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: READ 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='analytics', namespace='coinatmradar'}, New Cursor Field: timeStamp. Resetting cursor value 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 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 2023-02-01 19:04:59 source > 2023-02-01 19:04:59 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:04:59 destination > 2023-02-01 19:04:59 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2023-02-01 19:05:00 destination > 2023-02-01 19:05:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=coinatmradar_analytics, namespace=coinatmradar, outputSchemaName=coinatmradar, tmpTableName=_airbyte_tmp_lxp_coinatmradar_analytics, outputTableName=_airbyte_raw_coinatmradar_analytics, syncMode=append_dedup} 2023-02-01 19:05:00 destination > 2023-02-01 19:05:00 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2023-02-01 19:05:00 destination > 2023-02-01 19:05:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):116 - Preparing tmp tables in destination started for 1 streams 2023-02-01 19:05:00 destination > 2023-02-01 19:05:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):124 - Preparing staging area in destination started for schema coinatmradar stream coinatmradar_analytics: tmp table: _airbyte_tmp_lxp_coinatmradar_analytics, stage: 2023/02/01/19/8BCF799A-8F07-479F-8AF3-41D2649136D2/ 2023-02-01 19:05:00 destination > 2023-02-01 19:05:00 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:05:11 destination > 2023-02-01 19:05:11 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@490c7a83 2023-02-01 19:05:11 destination > 2023-02-01 19:05:11 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:05:12 destination > 2023-02-01 19:05:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:05:12 destination > 2023-02-01 19:05:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):131 - Preparing staging area in destination completed for schema coinatmradar stream coinatmradar_analytics 2023-02-01 19:05:12 destination > 2023-02-01 19:05:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):134 - Preparing tmp tables in destination completed. 2023-02-01 19:05:15 source > 2023-02-01 19:05:15 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46504}] to mongo-prod.localcoin.local:27017 2023-02-01 19:05:15 source > 2023-02-01 19:05:15 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46505}] to mongo-prod.localcoin.local:27017 2023-02-01 19:05:15 source > 2023-02-01 19:05:15 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=107300464} 2023-02-01 19:05:15 source > 2023-02-01 19:05:15 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46506}] to mongo-prod.localcoin.local:27017 2023-02-01 19:05:21 destination > 2023-02-01 19:05:21 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):47 - Starting a new buffer for stream coinatmradar_analytics (current state: 0 bytes in 0 buffers) 2023-02-01 19:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (351 KB) 2023-02-01 19:05:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (708 KB) 2023-02-01 19:05:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (1 MB) 2023-02-01 19:05:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (1 MB) 2023-02-01 19:05:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (1 MB) 2023-02-01 19:05:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (2 MB) 2023-02-01 19:05:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (2 MB) 2023-02-01 19:05:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (2 MB) 2023-02-01 19:05:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (3 MB) 2023-02-01 19:05:25 source > 2023-02-01 19:05:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 10000 2023-02-01 19:05:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (3 MB) 2023-02-01 19:05:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (3 MB) 2023-02-01 19:05:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (4 MB) 2023-02-01 19:05:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (4 MB) 2023-02-01 19:05:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (4 MB) 2023-02-01 19:05:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (5 MB) 2023-02-01 19:05:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (5 MB) 2023-02-01 19:05:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (6 MB) 2023-02-01 19:05:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (6 MB) 2023-02-01 19:05:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (6 MB) 2023-02-01 19:05:27 source > 2023-02-01 19:05:27 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 20000 2023-02-01 19:05:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (7 MB) 2023-02-01 19:05:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (7 MB) 2023-02-01 19:05:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (7 MB) 2023-02-01 19:05:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (8 MB) 2023-02-01 19:05:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (8 MB) 2023-02-01 19:05:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (8 MB) 2023-02-01 19:05:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (9 MB) 2023-02-01 19:05:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (9 MB) 2023-02-01 19:05:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (9 MB) 2023-02-01 19:05:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (10 MB) 2023-02-01 19:05:29 source > 2023-02-01 19:05:29 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 30000 2023-02-01 19:05:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (10 MB) 2023-02-01 19:05:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (10 MB) 2023-02-01 19:05:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (11 MB) 2023-02-01 19:05:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (11 MB) 2023-02-01 19:05:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (11 MB) 2023-02-01 19:05:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (12 MB) 2023-02-01 19:05:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (12 MB) 2023-02-01 19:05:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (13 MB) 2023-02-01 19:05:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (13 MB) 2023-02-01 19:05:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (13 MB) 2023-02-01 19:05:32 source > 2023-02-01 19:05:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 40000 2023-02-01 19:05:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (14 MB) 2023-02-01 19:05:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (14 MB) 2023-02-01 19:05:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (14 MB) 2023-02-01 19:05:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 43000 (15 MB) 2023-02-01 19:05:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 44000 (15 MB) 2023-02-01 19:05:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 45000 (15 MB) 2023-02-01 19:05:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 46000 (16 MB) 2023-02-01 19:05:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 47000 (16 MB) 2023-02-01 19:05:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 48000 (16 MB) 2023-02-01 19:05:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 49000 (17 MB) 2023-02-01 19:05:34 source > 2023-02-01 19:05:33 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 50000 2023-02-01 19:05:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 50000 (17 MB) 2023-02-01 19:05:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 51000 (17 MB) 2023-02-01 19:05:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 52000 (18 MB) 2023-02-01 19:05:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 53000 (18 MB) 2023-02-01 19:05:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 54000 (19 MB) 2023-02-01 19:05:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 55000 (19 MB) 2023-02-01 19:05:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 56000 (19 MB) 2023-02-01 19:05:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 57000 (20 MB) 2023-02-01 19:05:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 58000 (20 MB) 2023-02-01 19:05:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 59000 (20 MB) 2023-02-01 19:05:37 source > 2023-02-01 19:05:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 60000 2023-02-01 19:05:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 60000 (21 MB) 2023-02-01 19:05:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 61000 (21 MB) 2023-02-01 19:05:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 62000 (21 MB) 2023-02-01 19:05:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 63000 (22 MB) 2023-02-01 19:05:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 64000 (22 MB) 2023-02-01 19:05:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 65000 (22 MB) 2023-02-01 19:05:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 66000 (23 MB) 2023-02-01 19:05:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 67000 (23 MB) 2023-02-01 19:05:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 68000 (23 MB) 2023-02-01 19:05:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 69000 (24 MB) 2023-02-01 19:05:39 source > 2023-02-01 19:05:38 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 70000 2023-02-01 19:05:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 70000 (24 MB) 2023-02-01 19:05:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 71000 (24 MB) 2023-02-01 19:05:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 72000 (25 MB) 2023-02-01 19:05:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 73000 (25 MB) 2023-02-01 19:05:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 74000 (26 MB) 2023-02-01 19:05:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 75000 (26 MB) 2023-02-01 19:05:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 76000 (26 MB) 2023-02-01 19:05:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 77000 (27 MB) 2023-02-01 19:05:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 78000 (27 MB) 2023-02-01 19:05:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 79000 (27 MB) 2023-02-01 19:05:41 source > 2023-02-01 19:05:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 80000 2023-02-01 19:05:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 80000 (28 MB) 2023-02-01 19:05:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 81000 (28 MB) 2023-02-01 19:05:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 82000 (28 MB) 2023-02-01 19:05:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 83000 (29 MB) 2023-02-01 19:05:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 84000 (29 MB) 2023-02-01 19:05:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 85000 (29 MB) 2023-02-01 19:05:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 86000 (30 MB) 2023-02-01 19:05:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 87000 (30 MB) 2023-02-01 19:05:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 88000 (30 MB) 2023-02-01 19:05:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 89000 (31 MB) 2023-02-01 19:05:44 source > 2023-02-01 19:05:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 90000 2023-02-01 19:05:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 90000 (31 MB) 2023-02-01 19:05:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 91000 (31 MB) 2023-02-01 19:05:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 92000 (32 MB) 2023-02-01 19:05:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 93000 (32 MB) 2023-02-01 19:05:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 94000 (32 MB) 2023-02-01 19:05:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 95000 (33 MB) 2023-02-01 19:05:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 96000 (33 MB) 2023-02-01 19:05:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 97000 (33 MB) 2023-02-01 19:05:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 98000 (34 MB) 2023-02-01 19:05:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 99000 (34 MB) 2023-02-01 19:05:47 source > 2023-02-01 19:05:46 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 100000 2023-02-01 19:05:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 100000 (35 MB) 2023-02-01 19:05:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 101000 (35 MB) 2023-02-01 19:05:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 102000 (35 MB) 2023-02-01 19:05:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 103000 (36 MB) 2023-02-01 19:05:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 104000 (36 MB) 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 105000 (36 MB) 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 106000 (37 MB) 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 107000 (37 MB) 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 108000 (37 MB) 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 109000 (38 MB) 2023-02-01 19:05:48 source > 2023-02-01 19:05:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 110000 2023-02-01 19:05:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 110000 (38 MB) 2023-02-01 19:05:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 111000 (38 MB) 2023-02-01 19:05:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 112000 (39 MB) 2023-02-01 19:05:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 113000 (39 MB) 2023-02-01 19:05:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 114000 (40 MB) 2023-02-01 19:05:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 115000 (40 MB) 2023-02-01 19:05:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 116000 (40 MB) 2023-02-01 19:05:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 117000 (41 MB) 2023-02-01 19:05:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 118000 (41 MB) 2023-02-01 19:05:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 119000 (41 MB) 2023-02-01 19:05:50 source > 2023-02-01 19:05:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 120000 2023-02-01 19:05:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 120000 (42 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 121000 (42 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 122000 (42 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 123000 (43 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 124000 (43 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 125000 (43 MB) 2023-02-01 19:05:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 126000 (44 MB) 2023-02-01 19:05:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 127000 (44 MB) 2023-02-01 19:05:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 128000 (44 MB) 2023-02-01 19:05:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 129000 (45 MB) 2023-02-01 19:05:52 source > 2023-02-01 19:05:52 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 130000 2023-02-01 19:05:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 130000 (45 MB) 2023-02-01 19:05:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 131000 (45 MB) 2023-02-01 19:05:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 132000 (46 MB) 2023-02-01 19:05:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 133000 (46 MB) 2023-02-01 19:05:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 134000 (47 MB) 2023-02-01 19:05:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 135000 (47 MB) 2023-02-01 19:05:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 136000 (47 MB) 2023-02-01 19:05:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 137000 (48 MB) 2023-02-01 19:05:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 138000 (48 MB) 2023-02-01 19:05:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 139000 (48 MB) 2023-02-01 19:05:54 source > 2023-02-01 19:05:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 140000 2023-02-01 19:05:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 140000 (49 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 141000 (49 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 142000 (49 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 143000 (50 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 144000 (50 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 145000 (50 MB) 2023-02-01 19:05:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 146000 (51 MB) 2023-02-01 19:05:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 147000 (51 MB) 2023-02-01 19:05:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 148000 (51 MB) 2023-02-01 19:05:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 149000 (52 MB) 2023-02-01 19:05:56 source > 2023-02-01 19:05:55 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 150000 2023-02-01 19:05:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 150000 (52 MB) 2023-02-01 19:05:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 151000 (53 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 152000 (53 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 153000 (53 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 154000 (54 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 155000 (54 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 156000 (54 MB) 2023-02-01 19:05:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 157000 (55 MB) 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 158000 (55 MB) 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 159000 (55 MB) 2023-02-01 19:05:58 source > 2023-02-01 19:05:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 160000 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 160000 (56 MB) 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 161000 (56 MB) 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 162000 (56 MB) 2023-02-01 19:05:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 163000 (57 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 164000 (57 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 165000 (57 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 166000 (58 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 167000 (58 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 168000 (59 MB) 2023-02-01 19:05:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 169000 (59 MB) 2023-02-01 19:06:00 source > 2023-02-01 19:05:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 170000 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 170000 (59 MB) 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 171000 (60 MB) 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 172000 (60 MB) 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 173000 (60 MB) 2023-02-01 19:06:00 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2023-02-01 19:06:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 174000 (61 MB) 2023-02-01 19:06:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 175000 (61 MB) 2023-02-01 19:06:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 176000 (61 MB) 2023-02-01 19:06:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 177000 (62 MB) 2023-02-01 19:06:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 178000 (62 MB) 2023-02-01 19:06:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 179000 (62 MB) 2023-02-01 19:06:02 source > 2023-02-01 19:06:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 180000 2023-02-01 19:06:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 180000 (63 MB) 2023-02-01 19:06:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 181000 (63 MB) 2023-02-01 19:06:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 182000 (63 MB) 2023-02-01 19:06:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 183000 (64 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 184000 (64 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 185000 (64 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 186000 (65 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 187000 (65 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 188000 (66 MB) 2023-02-01 19:06:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 189000 (66 MB) 2023-02-01 19:06:04 source > 2023-02-01 19:06:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 190000 2023-02-01 19:06:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 190000 (66 MB) 2023-02-01 19:06:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 191000 (67 MB) 2023-02-01 19:06:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 192000 (67 MB) 2023-02-01 19:06:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 193000 (67 MB) 2023-02-01 19:06:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 194000 (68 MB) 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 195000 (68 MB) 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 196000 (68 MB) 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 197000 (69 MB) 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 198000 (69 MB) 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 199000 (69 MB) 2023-02-01 19:06:05 source > 2023-02-01 19:06:05 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 200000 2023-02-01 19:06:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 200000 (70 MB) 2023-02-01 19:06:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 201000 (70 MB) 2023-02-01 19:06:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 202000 (70 MB) 2023-02-01 19:06:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 203000 (71 MB) 2023-02-01 19:06:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 204000 (71 MB) 2023-02-01 19:06:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 205000 (72 MB) 2023-02-01 19:06:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 206000 (72 MB) 2023-02-01 19:06:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 207000 (72 MB) 2023-02-01 19:06:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 208000 (73 MB) 2023-02-01 19:06:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 209000 (73 MB) 2023-02-01 19:06:08 source > 2023-02-01 19:06:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 210000 2023-02-01 19:06:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 210000 (73 MB) 2023-02-01 19:06:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 211000 (74 MB) 2023-02-01 19:06:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 212000 (74 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 213000 (74 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 214000 (75 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 215000 (75 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 216000 (75 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 217000 (76 MB) 2023-02-01 19:06:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 218000 (76 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 219000 (76 MB) 2023-02-01 19:06:10 source > 2023-02-01 19:06:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 220000 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 220000 (77 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 221000 (77 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 222000 (78 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 223000 (78 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 223019 (78 MB) 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2023-02-01 19:06:10 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2023-02-01 19:06:10 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:06:10 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - 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.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Suppressed: java.io.IOException: Stream closed at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?] at java.io.OutputStream.write(OutputStream.java:164) ~[?:?] at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:125) ~[?:?] at java.io.BufferedOutputStream.implFlush(BufferedOutputStream.java:251) ~[?:?] at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:245) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:416) ~[?:?] at sun.nio.cs.StreamEncoder.lockedFlush(StreamEncoder.java:218) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:205) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:263) ~[?:?] at java.io.BufferedWriter.implFlush(BufferedWriter.java:372) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:359) ~[?:?] at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:06:10 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2023-02-01 19:06:10 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2023-02-01 19:06:10 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2023-02-01 19:06:10 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:06:10 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):312 - Stopping temporal heartbeating... 2023-02-01 19:06:10 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2023-02-01 19:06:10 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=86d1a4c1-dea5-31b5-aded-8046750af71b, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:310) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6f3f977b[status=cancelled,recordsSynced=223019,bytesSynced=82163966,startTime=1675278297728,endTime=1675278370795,totalStats=io.airbyte.config.SyncStats@145170e6[recordsEmitted=223019,bytesEmitted=82163966,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@2f47f0d0[streamName=coinatmradar_analytics,stats=io.airbyte.config.SyncStats@4ed80a3a[recordsEmitted=223019,bytesEmitted=82163966,stateMessagesEmitted=,recordsCommitted=]]]] 2023-02-01 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2023-02-01 19:06:10 WARN i.a.w.g.DefaultReplicationWorker(run):277 - State capture: No new state, falling back on input state: io.airbyte.config.State@428645ca[state={}] 2023-02-01 19:06:01 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 2023-02-01 19:06:01 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.private_key: is missing but it is required 2023-02-01 19:06:01 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2023-02-01 19:06:01 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/1/logs.log 2023-02-01 19:06:01 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:06:01 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:06:01 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:06:01 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:06:01 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name source-mongodb-v2-check-27-1-cvplj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 check --config source_config.json 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 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 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 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 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 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 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:06:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:08 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46507}] to mongo-prod.localcoin.local:27017 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=109813294} 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46508}] to mongo-prod.localcoin.local:27017 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46509}] to mongo-prod.localcoin.local:27017 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO i.a.i.s.m.MongoDbSource(lambda$getCheckOperations$0):95 - The source passed the basic operation test! 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:06:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:24 INFO i.a.i.s.m.MongoDbSource(main):65 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:06:25 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:06:25 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/1/logs.log 2023-02-01 19:06:25 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:06:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:06:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:06:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:06:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name destination-snowflake-check-27-1-gxlts --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:06:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:06:27 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] 2023-02-01 19:06:27 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] 2023-02-01 19:06:27 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] 2023-02-01 19:06:27 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] 2023-02-01 19:06:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:06:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 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 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 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 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 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 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 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 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:06:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:28 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:06:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:41 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:06:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:41 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:06:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:41 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:06:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:42 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:06:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:43 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:06:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:06:43 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:06:44 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:06:54 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999598415s. [closed=[], open=[[buffered_nanos=10000186469, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:07:26 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/1/logs.log 2023-02-01 19:07:26 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:07:26 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:07:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:07:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:07:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name destination-snowflake-check-27-1-ugywu --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:07:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:07:29 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] 2023-02-01 19:07:29 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] 2023-02-01 19:07:29 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] 2023-02-01 19:07:29 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] 2023-02-01 19:07:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:07:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:07:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:07:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:29 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:07:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:29 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:07:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:29 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 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 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 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 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 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 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 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 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:07:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:30 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:07:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:42 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:07:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:42 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:07:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:42 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:07:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:43 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:07:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:43 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:07:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:07:43 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:07:44 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:07:54 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999722795s. [closed=[], open=[[buffered_nanos=10000001793, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:08:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/1/logs.log 2023-02-01 19:08:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:09:07 WARN i.t.i.a.HeartbeatContextImpl(doHeartBeatLocked):145 - Heartbeat failed io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999781824s. [closed=[], open=[[buffered_nanos=10000281759, waiting_for_connection]]] 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.recordActivityTaskHeartbeat(WorkflowServiceGrpc.java:2716) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.client.ActivityClientHelper.sendHeartbeatRequest(ActivityClientHelper.java:61) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.sendHeartbeatRequest(HeartbeatContextImpl.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.doHeartBeatLocked(HeartbeatContextImpl.java:139) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.heartbeat(HeartbeatContextImpl.java:108) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.ActivityExecutionContextImpl.heartbeat(ActivityExecutionContextImpl.java:93) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:50) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:122) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.check.connection.CheckConnectionActivityImpl.runWithJobOutput(CheckConnectionActivityImpl.java:79) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:09:07 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:09:07 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:09:07 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:09:07 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name destination-snowflake-check-27-1-jsnmi --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:09:08 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:09:08 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] 2023-02-01 19:09:08 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] 2023-02-01 19:09:08 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] 2023-02-01 19:09:08 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] 2023-02-01 19:09:08 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:09:09 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 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 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 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 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 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 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 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 2023-02-01 19:09:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:09 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:09:10 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:10 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:09:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:26 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:09:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:26 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:09:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:09:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:27 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:09:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:28 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:09:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:09:28 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:09:29 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:09:29 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/1/logs.log 2023-02-01 19:09:29 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:09:29 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 27 attempt id: 1 2023-02-01 19:09:29 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {coinatmradar.analytics=incremental - append_dedup} 2023-02-01 19:09:29 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2023-02-01 19:09:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:09:29 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:09:29 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:09:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name destination-snowflake-write-27-1-jzrdx --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 write --config destination_config.json --catalog destination_catalog.json 2023-02-01 19:09:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:09:30 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:09:30 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:09:30 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/1 --log-driver none --name source-mongodb-v2-read-27-1-vlmeh --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 read --config source_config.json --catalog source_catalog.json --state input_state.json 2023-02-01 19:09:30 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2023-02-01 19:09:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2023-02-01 19:09:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2023-02-01 19:09:32 destination > SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:09:32 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:09:32 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:09:32 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:09:32 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:09:32 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:09:32 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: READ 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='analytics', namespace='coinatmradar'}, New Cursor Field: timeStamp. Resetting cursor value 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:09:33 source > 2023-02-01 19:09:33 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 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 2023-02-01 19:09:33 destination > 2023-02-01 19:09:33 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2023-02-01 19:09:34 destination > 2023-02-01 19:09:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=coinatmradar_analytics, namespace=coinatmradar, outputSchemaName=coinatmradar, tmpTableName=_airbyte_tmp_ixq_coinatmradar_analytics, outputTableName=_airbyte_raw_coinatmradar_analytics, syncMode=append_dedup} 2023-02-01 19:09:34 destination > 2023-02-01 19:09:34 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2023-02-01 19:09:34 destination > 2023-02-01 19:09:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):116 - Preparing tmp tables in destination started for 1 streams 2023-02-01 19:09:34 destination > 2023-02-01 19:09:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):124 - Preparing staging area in destination started for schema coinatmradar stream coinatmradar_analytics: tmp table: _airbyte_tmp_ixq_coinatmradar_analytics, stage: 2023/02/01/19/8BFABAF1-2AE8-4AC9-A7C3-14A0136B2B61/ 2023-02-01 19:09:34 destination > 2023-02-01 19:09:34 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:09:45 destination > 2023-02-01 19:09:45 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@6015a4a5 2023-02-01 19:09:45 destination > 2023-02-01 19:09:45 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:09:46 destination > 2023-02-01 19:09:46 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:09:46 destination > 2023-02-01 19:09:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):131 - Preparing staging area in destination completed for schema coinatmradar stream coinatmradar_analytics 2023-02-01 19:09:46 destination > 2023-02-01 19:09:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):134 - Preparing tmp tables in destination completed. 2023-02-01 19:09:49 source > 2023-02-01 19:09:49 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46510}] to mongo-prod.localcoin.local:27017 2023-02-01 19:09:49 source > 2023-02-01 19:09:49 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46511}] to mongo-prod.localcoin.local:27017 2023-02-01 19:09:49 source > 2023-02-01 19:09:49 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=131374263} 2023-02-01 19:09:49 source > 2023-02-01 19:09:49 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46512}] to mongo-prod.localcoin.local:27017 2023-02-01 19:09:55 destination > 2023-02-01 19:09:55 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):47 - Starting a new buffer for stream coinatmradar_analytics (current state: 0 bytes in 0 buffers) 2023-02-01 19:09:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (351 KB) 2023-02-01 19:09:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (708 KB) 2023-02-01 19:09:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (1 MB) 2023-02-01 19:09:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (1 MB) 2023-02-01 19:09:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (1 MB) 2023-02-01 19:09:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (2 MB) 2023-02-01 19:09:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (2 MB) 2023-02-01 19:09:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (2 MB) 2023-02-01 19:10:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (3 MB) 2023-02-01 19:10:00 source > 2023-02-01 19:10:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 10000 2023-02-01 19:10:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (3 MB) 2023-02-01 19:10:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (3 MB) 2023-02-01 19:10:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (4 MB) 2023-02-01 19:10:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (4 MB) 2023-02-01 19:10:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (4 MB) 2023-02-01 19:10:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (5 MB) 2023-02-01 19:10:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (5 MB) 2023-02-01 19:10:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (6 MB) 2023-02-01 19:10:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (6 MB) 2023-02-01 19:10:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (6 MB) 2023-02-01 19:10:03 source > 2023-02-01 19:10:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 20000 2023-02-01 19:10:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (7 MB) 2023-02-01 19:10:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (7 MB) 2023-02-01 19:10:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (7 MB) 2023-02-01 19:10:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (8 MB) 2023-02-01 19:10:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (8 MB) 2023-02-01 19:10:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (8 MB) 2023-02-01 19:10:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (9 MB) 2023-02-01 19:10:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (9 MB) 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (9 MB) 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (10 MB) 2023-02-01 19:10:06 source > 2023-02-01 19:10:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 30000 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (10 MB) 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (10 MB) 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (11 MB) 2023-02-01 19:10:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (11 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (11 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (12 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (12 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (13 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (13 MB) 2023-02-01 19:10:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (13 MB) 2023-02-01 19:10:08 source > 2023-02-01 19:10:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 40000 2023-02-01 19:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (14 MB) 2023-02-01 19:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (14 MB) 2023-02-01 19:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (14 MB) 2023-02-01 19:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 43000 (15 MB) 2023-02-01 19:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 44000 (15 MB) 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 45000 (15 MB) 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 46000 (16 MB) 2023-02-01 19:10:09 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 47000 (16 MB) 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 48000 (16 MB) 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 49000 (17 MB) 2023-02-01 19:10:09 source > 2023-02-01 19:10:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 50000 2023-02-01 19:10:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 50000 (17 MB) 2023-02-01 19:10:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 51000 (17 MB) 2023-02-01 19:10:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 52000 (18 MB) 2023-02-01 19:10:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 53000 (18 MB) 2023-02-01 19:10:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 54000 (19 MB) 2023-02-01 19:10:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 55000 (19 MB) 2023-02-01 19:10:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 56000 (19 MB) 2023-02-01 19:10:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 57000 (20 MB) 2023-02-01 19:10:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 58000 (20 MB) 2023-02-01 19:10:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 59000 (20 MB) 2023-02-01 19:10:11 source > 2023-02-01 19:10:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 60000 2023-02-01 19:10:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 60000 (21 MB) 2023-02-01 19:10:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 61000 (21 MB) 2023-02-01 19:10:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 62000 (21 MB) 2023-02-01 19:10:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 63000 (22 MB) 2023-02-01 19:10:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 64000 (22 MB) 2023-02-01 19:10:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 65000 (22 MB) 2023-02-01 19:10:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 66000 (23 MB) 2023-02-01 19:10:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 67000 (23 MB) 2023-02-01 19:10:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 68000 (23 MB) 2023-02-01 19:10:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 69000 (24 MB) 2023-02-01 19:10:13 source > 2023-02-01 19:10:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 70000 2023-02-01 19:10:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 70000 (24 MB) 2023-02-01 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 71000 (24 MB) 2023-02-01 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 72000 (25 MB) 2023-02-01 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 73000 (25 MB) 2023-02-01 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 74000 (26 MB) 2023-02-01 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 75000 (26 MB) 2023-02-01 19:10:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 76000 (26 MB) 2023-02-01 19:10:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 77000 (27 MB) 2023-02-01 19:10:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 78000 (27 MB) 2023-02-01 19:10:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 79000 (27 MB) 2023-02-01 19:10:15 source > 2023-02-01 19:10:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 80000 2023-02-01 19:10:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 80000 (28 MB) 2023-02-01 19:10:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 81000 (28 MB) 2023-02-01 19:10:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 82000 (28 MB) 2023-02-01 19:10:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 83000 (29 MB) 2023-02-01 19:10:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 84000 (29 MB) 2023-02-01 19:10:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 85000 (29 MB) 2023-02-01 19:10:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 86000 (30 MB) 2023-02-01 19:10:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 87000 (30 MB) 2023-02-01 19:10:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 88000 (30 MB) 2023-02-01 19:10:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 89000 (31 MB) 2023-02-01 19:10:18 source > 2023-02-01 19:10:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 90000 2023-02-01 19:10:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 90000 (31 MB) 2023-02-01 19:10:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 91000 (31 MB) 2023-02-01 19:10:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 92000 (32 MB) 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 93000 (32 MB) 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 93179 (32 MB) 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2023-02-01 19:10:19 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2023-02-01 19:10:19 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:10:19 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2023-02-01 19:10:19 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2023-02-01 19:10:19 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2023-02-01 19:10:19 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2023-02-01 19:10:19 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:10:19 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2023-02-01 19:10:19 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):312 - Stopping temporal heartbeating... 2023-02-01 19:10:19 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - 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.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 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.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6e032370[status=cancelled,recordsSynced=93179,bytesSynced=34266930,startTime=1675278569216,endTime=1675278619244,totalStats=io.airbyte.config.SyncStats@6d0a82b5[recordsEmitted=93179,bytesEmitted=34266930,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@488ee860[streamName=coinatmradar_analytics,stats=io.airbyte.config.SyncStats@45e0812f[recordsEmitted=93179,bytesEmitted=34266930,stateMessagesEmitted=,recordsCommitted=]]]] 2023-02-01 19:10:19 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=afa9dd4e-e14c-3e08-b853-321d6159cc09, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:310) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2023-02-01 19:10:19 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2023-02-01 19:10:19 WARN i.a.w.g.DefaultReplicationWorker(run):277 - State capture: No new state, falling back on input state: io.airbyte.config.State@320f3240[state={}] 2023-02-01 19:10:08 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 2023-02-01 19:10:08 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.private_key: is missing but it is required 2023-02-01 19:10:08 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2023-02-01 19:10:08 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/2/logs.log 2023-02-01 19:10:08 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:10:08 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:10:08 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:10:08 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:10:08 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name source-mongodb-v2-check-27-2-sbluy --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 check --config source_config.json 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 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 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 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 2023-02-01 19:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:11 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 2023-02-01 19:10:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:12 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:10:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:12 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46513}] to mongo-prod.localcoin.local:27017 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=117830652} 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46514}] to mongo-prod.localcoin.local:27017 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46515}] to mongo-prod.localcoin.local:27017 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO i.a.i.s.m.MongoDbSource(lambda$getCheckOperations$0):95 - The source passed the basic operation test! 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:10:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:27 INFO i.a.i.s.m.MongoDbSource(main):65 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:10:28 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:10:28 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/2/logs.log 2023-02-01 19:10:28 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:10:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:10:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:10:28 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:10:28 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name destination-snowflake-check-27-2-bcdro --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:10:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:10:29 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] 2023-02-01 19:10:29 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] 2023-02-01 19:10:29 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] 2023-02-01 19:10:29 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] 2023-02-01 19:10:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:10:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:10:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:10:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:29 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:10:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:29 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:10:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:29 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 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 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 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 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 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 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 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 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:10:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:30 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:10:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:41 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:10:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:41 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:10:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:42 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:10:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:42 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:10:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:43 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:10:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:10:43 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:10:44 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:10:54 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999695168s. [closed=[], open=[[buffered_nanos=9999988856, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:11:29 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/2/logs.log 2023-02-01 19:11:29 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:11:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:11:29 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:11:29 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:11:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name destination-snowflake-check-27-2-zdluc --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:11:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:11: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] 2023-02-01 19:11:31 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] 2023-02-01 19:11:31 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] 2023-02-01 19:11:31 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] 2023-02-01 19:11:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:11:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 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 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 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 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 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 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 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 2023-02-01 19:11:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:31 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:11:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:32 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:11:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:44 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:11:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:44 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:11:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:44 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:11:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:45 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:11:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:45 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:11:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:11:45 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:11:46 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:11:56 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999823753s. [closed=[], open=[[buffered_nanos=10000000958, waiting_for_connection]]] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:13:00 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/2/logs.log 2023-02-01 19:13:00 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:13:10 WARN i.t.i.a.HeartbeatContextImpl(doHeartBeatLocked):145 - Heartbeat failed io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999838185s. [closed=[], open=[[buffered_nanos=10000258893, waiting_for_connection]]] 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.recordActivityTaskHeartbeat(WorkflowServiceGrpc.java:2716) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.client.ActivityClientHelper.sendHeartbeatRequest(ActivityClientHelper.java:61) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.sendHeartbeatRequest(HeartbeatContextImpl.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.doHeartBeatLocked(HeartbeatContextImpl.java:139) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.HeartbeatContextImpl.heartbeat(HeartbeatContextImpl.java:108) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.ActivityExecutionContextImpl.heartbeat(ActivityExecutionContextImpl.java:93) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:50) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:122) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.check.connection.CheckConnectionActivityImpl.runWithJobOutput(CheckConnectionActivityImpl.java:79) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:13:10 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:13:10 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:13:10 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:13:10 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name destination-snowflake-check-27-2-gjeqi --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 check --config source_config.json 2023-02-01 19:13:13 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:13:13 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] 2023-02-01 19:13:13 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] 2023-02-01 19:13:13 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] 2023-02-01 19:13:13 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] 2023-02-01 19:13:13 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:13:13 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 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 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 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 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 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 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 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 2023-02-01 19:13:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:13 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2023-02-01 19:13:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:14 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:13:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:25 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@571a01f9 2023-02-01 19:13:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:25 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:13:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:25 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:13:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:26 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2023-02-01 19:13:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:27 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2023-02-01 19:13:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2023-02-01 19:13:27 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:13:28 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:13:28 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/27/2/logs.log 2023-02-01 19:13:28 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.42-alpha 2023-02-01 19:13:28 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 27 attempt id: 2 2023-02-01 19:13:28 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {coinatmradar.analytics=incremental - append_dedup} 2023-02-01 19:13:28 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2023-02-01 19:13:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.34 exists... 2023-02-01 19:13:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.34 was found locally. 2023-02-01 19:13:28 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:13:28 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name destination-snowflake-write-27-2-febcx --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.34 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/destination-snowflake:0.4.34 write --config destination_config.json --catalog destination_catalog.json 2023-02-01 19:13:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.15 exists... 2023-02-01 19:13:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.15 was found locally. 2023-02-01 19:13:28 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 27 2023-02-01 19:13:28 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/27/2 --log-driver none --name source-mongodb-v2-read-27-2-jghby --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.42-alpha -e WORKER_JOB_ID=27 airbyte/source-mongodb-v2:0.1.15 read --config source_config.json --catalog source_catalog.json --state input_state.json 2023-02-01 19:13:28 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2023-02-01 19:13:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2023-02-01 19:13:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2023-02-01 19:13:29 destination > SLF4J: Class path contains multiple SLF4J bindings. 2023-02-01 19:13:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:13:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:13:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:13:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-01 19:13:29 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-01 19:13:29 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-01 19:13:29 source > 2023-02-01 19:13:29 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:13:29 source > 2023-02-01 19:13:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2023-02-01 19:13:29 source > 2023-02-01 19:13:29 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2023-02-01 19:13:29 source > 2023-02-01 19:13:29 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: READ 2023-02-01 19:13:29 source > 2023-02-01 19:13:29 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='analytics', namespace='coinatmradar'}, New Cursor Field: timeStamp. Resetting cursor value 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[mongo-prod.localcoin.local:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2023-02-01 19:13:30 source > 2023-02-01 19:13:30 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 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 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=coinatmradar_analytics, namespace=coinatmradar, outputSchemaName=coinatmradar, tmpTableName=_airbyte_tmp_ala_coinatmradar_analytics, outputTableName=_airbyte_raw_coinatmradar_analytics, syncMode=append_dedup} 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):116 - Preparing tmp tables in destination started for 1 streams 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):124 - Preparing staging area in destination started for schema coinatmradar stream coinatmradar_analytics: tmp table: _airbyte_tmp_ala_coinatmradar_analytics, stage: 2023/02/01/19/CFCAA1B3-186C-457A-8A2D-C8013DA0AC13/ 2023-02-01 19:13:30 destination > 2023-02-01 19:13:30 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2023-02-01 19:13:42 destination > 2023-02-01 19:13:42 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@61ab89b0 2023-02-01 19:13:42 destination > 2023-02-01 19:13:42 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2023-02-01 19:13:42 destination > 2023-02-01 19:13:42 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2023-02-01 19:13:43 destination > 2023-02-01 19:13:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):131 - Preparing staging area in destination completed for schema coinatmradar stream coinatmradar_analytics 2023-02-01 19:13:43 destination > 2023-02-01 19:13:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):134 - Preparing tmp tables in destination completed. 2023-02-01 19:13:45 source > 2023-02-01 19:13:45 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:46516}] to mongo-prod.localcoin.local:27017 2023-02-01 19:13:45 source > 2023-02-01 19:13:45 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:46517}] to mongo-prod.localcoin.local:27017 2023-02-01 19:13:45 source > 2023-02-01 19:13:45 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=mongo-prod.localcoin.local:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=166428086} 2023-02-01 19:13:46 source > 2023-02-01 19:13:46 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:46518}] to mongo-prod.localcoin.local:27017 2023-02-01 19:13:51 destination > 2023-02-01 19:13:51 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):47 - Starting a new buffer for stream coinatmradar_analytics (current state: 0 bytes in 0 buffers) 2023-02-01 19:13:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (351 KB) 2023-02-01 19:13:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (708 KB) 2023-02-01 19:13:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (1 MB) 2023-02-01 19:13:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (1 MB) 2023-02-01 19:13:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (1 MB) 2023-02-01 19:13:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (2 MB) 2023-02-01 19:13:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (2 MB) 2023-02-01 19:13:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (2 MB) 2023-02-01 19:13:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (3 MB) 2023-02-01 19:13:55 source > 2023-02-01 19:13:55 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 10000 2023-02-01 19:13:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (3 MB) 2023-02-01 19:13:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (3 MB) 2023-02-01 19:13:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (4 MB) 2023-02-01 19:13:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (4 MB) 2023-02-01 19:13:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (4 MB) 2023-02-01 19:13:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (5 MB) 2023-02-01 19:13:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (5 MB) 2023-02-01 19:13:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (6 MB) 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (6 MB) 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (6 MB) 2023-02-01 19:13:57 source > 2023-02-01 19:13:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 20000 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (7 MB) 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (7 MB) 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (7 MB) 2023-02-01 19:13:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (8 MB) 2023-02-01 19:13:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (8 MB) 2023-02-01 19:13:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (8 MB) 2023-02-01 19:13:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (9 MB) 2023-02-01 19:13:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (9 MB) 2023-02-01 19:13:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (9 MB) 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (10 MB) 2023-02-01 19:13:59 source > 2023-02-01 19:13:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 30000 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (10 MB) 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (10 MB) 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (11 MB) 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (11 MB) 2023-02-01 19:13:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (11 MB) 2023-02-01 19:14:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (12 MB) 2023-02-01 19:14:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (12 MB) 2023-02-01 19:14:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (13 MB) 2023-02-01 19:14:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (13 MB) 2023-02-01 19:14:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (13 MB) 2023-02-01 19:14:01 source > 2023-02-01 19:14:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 40000 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (14 MB) 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (14 MB) 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (14 MB) 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 43000 (15 MB) 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 44000 (15 MB) 2023-02-01 19:14:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 45000 (15 MB) 2023-02-01 19:14:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 46000 (16 MB) 2023-02-01 19:14:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 47000 (16 MB) 2023-02-01 19:14:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 48000 (16 MB) 2023-02-01 19:14:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 49000 (17 MB) 2023-02-01 19:14:02 source > 2023-02-01 19:14:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 50000 2023-02-01 19:14:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 50000 (17 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 51000 (17 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 52000 (18 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 53000 (18 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 54000 (19 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 55000 (19 MB) 2023-02-01 19:14:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 56000 (19 MB) 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 57000 (20 MB) 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 58000 (20 MB) 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 59000 (20 MB) 2023-02-01 19:14:04 source > 2023-02-01 19:14:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 60000 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 60000 (21 MB) 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 61000 (21 MB) 2023-02-01 19:14:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 62000 (21 MB) 2023-02-01 19:14:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 63000 (22 MB) 2023-02-01 19:14:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 64000 (22 MB) 2023-02-01 19:14:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 65000 (22 MB) 2023-02-01 19:14:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 66000 (23 MB) 2023-02-01 19:14:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 67000 (23 MB) 2023-02-01 19:14:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 68000 (23 MB) 2023-02-01 19:14:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 69000 (24 MB) 2023-02-01 19:14:06 source > 2023-02-01 19:14:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 70000 2023-02-01 19:14:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 70000 (24 MB) 2023-02-01 19:14:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 71000 (24 MB) 2023-02-01 19:14:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 72000 (25 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 73000 (25 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 74000 (26 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 75000 (26 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 76000 (26 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 77000 (27 MB) 2023-02-01 19:14:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 78000 (27 MB) 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 79000 (27 MB) 2023-02-01 19:14:08 source > 2023-02-01 19:14:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 80000 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 80000 (28 MB) 2023-02-01 19:14:08 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 81000 (28 MB) 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 82000 (28 MB) 2023-02-01 19:14:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 83000 (29 MB) 2023-02-01 19:14:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 84000 (29 MB) 2023-02-01 19:14:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 85000 (29 MB) 2023-02-01 19:14:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 86000 (30 MB) 2023-02-01 19:14:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 87000 (30 MB) 2023-02-01 19:14:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 88000 (30 MB) 2023-02-01 19:14:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 89000 (31 MB) 2023-02-01 19:14:10 source > 2023-02-01 19:14:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 90000 2023-02-01 19:14:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 90000 (31 MB) 2023-02-01 19:14:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 91000 (31 MB) 2023-02-01 19:14:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 92000 (32 MB) 2023-02-01 19:14:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 93000 (32 MB) 2023-02-01 19:14:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 94000 (32 MB) 2023-02-01 19:14:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 95000 (33 MB) 2023-02-01 19:14:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 96000 (33 MB) 2023-02-01 19:14:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 97000 (33 MB) 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 98000 (34 MB) 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 99000 (34 MB) 2023-02-01 19:14:12 source > 2023-02-01 19:14:12 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 100000 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 100000 (35 MB) 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 101000 (35 MB) 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 102000 (35 MB) 2023-02-01 19:14:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 103000 (36 MB) 2023-02-01 19:14:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 104000 (36 MB) 2023-02-01 19:14:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 105000 (36 MB) 2023-02-01 19:14:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 106000 (37 MB) 2023-02-01 19:14:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 107000 (37 MB) 2023-02-01 19:14:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 108000 (37 MB) 2023-02-01 19:14:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 109000 (38 MB) 2023-02-01 19:14:15 source > 2023-02-01 19:14:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):256 - Reading stream analytics. Records read: 110000 2023-02-01 19:14:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 110000 (38 MB) 2023-02-01 19:14:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 111000 (38 MB) 2023-02-01 19:14:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 112000 (39 MB) 2023-02-01 19:14:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 113000 (39 MB) 2023-02-01 19:14:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 114000 (40 MB) 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 114661 (40 MB) 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2023-02-01 19:14:18 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2023-02-01 19:14:18 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2023-02-01 19:14:18 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2023-02-01 19:14:18 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2023-02-01 19:14:18 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2023-02-01 19:14:18 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2023-02-01 19:14:18 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2023-02-01 19:14:18 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):312 - Stopping temporal heartbeating... 2023-02-01 19:14:18 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - 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.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 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.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2023-02-01 19:14:18 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2023-02-01 19:14:18 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=e7c506c6-9e38-3340-9267-d5bb7f25e3d3, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:310) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.42-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@35abcbfe[status=cancelled,recordsSynced=114661,bytesSynced=42211267,startTime=1675278808373,endTime=1675278858400,totalStats=io.airbyte.config.SyncStats@3ed0bc26[recordsEmitted=114661,bytesEmitted=42211267,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@14313336[streamName=coinatmradar_analytics,stats=io.airbyte.config.SyncStats@2adb37f5[recordsEmitted=114661,bytesEmitted=42211267,stateMessagesEmitted=,recordsCommitted=]]]] 2023-02-01 19:14:18 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2023-02-01 19:14:18 WARN i.a.w.g.DefaultReplicationWorker(run):277 - State capture: No new state, falling back on input state: io.airbyte.config.State@41c4ed6b[state={}]