2022-04-23 13:03:32 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-04-23 13:03:32 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/2/0/logs.log 2022-04-23 13:03:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-04-23 13:03:32 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 2 attempt id: 0 2022-04-23 13:03:32 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {tracking.LocalUser=incremental - append, tracking.LocalGroup=incremental - append} 2022-04-23 13:03:32 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-23 13:03:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery-denormalized:0.3.1 exists... 2022-04-23 13:03:33 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery-denormalized:0.3.1 was found locally. 2022-04-23 13:03:33 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 2 2022-04-23 13:03:33 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/2/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery-denormalized:0.3.1 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=2 airbyte/destination-bigquery-denormalized:0.3.1 write --config destination_config.json --catalog destination_catalog.json 2022-04-23 13:03:33 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.6 exists... 2022-04-23 13:03:33 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.6 was found locally. 2022-04-23 13:03:33 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 2 2022-04-23 13:03:33 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/2/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.6 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=2 airbyte/source-mysql:0.5.6 read --config source_config.json --catalog source_catalog.json 2022-04-23 13:03:33 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-23 13:03:33 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-23 13:03:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-23 13:03:34 source > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-23 13:03:34 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-23 13:03:34 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-23 13:03:34 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-23 13:03:34 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-23 13:03:34 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-23 13:03:34 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-23 13:03:34 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-23 13:03:34 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-23 13:03:35 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-23 13:03:37 source > 2022-04-23 13:03:37 INFO i.a.i.s.m.MySqlSource(main):206 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource 2022-04-23 13:03:46 destination > 2022-04-23 13:03:45 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-23 13:04:20 destination > 2022-04-23 13:04:06 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination 2022-04-23 13:04:47 destination > 2022-04-23 13:04:26 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-23 13:04:56 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 69.999934711s. [closed=[], open=[[remote_addr=airbyte-temporal/172.18.0.9:7233]]] at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1] at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-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.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.8.1.jar:?] at jdk.proxy2.$Proxy40.run(Unknown Source) ~[?:?] at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:151) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:498) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:150) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:49) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.36.1-alpha.jar:?] at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.36.1-alpha.jar:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-23 13:04:57 destination > 2022-04-23 13:04:42 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-23 13:05:03 source > 2022-04-23 13:05:03 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json} 2022-04-23 13:05:04 source > 2022-04-23 13:05:04 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: c092c401f2294723a5a252522d86717d 2022-04-23 13:05:04 source > 2022-04-23 13:05:04 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-04-23 13:05:04 source > 2022-04-23 13:05:04 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ 2022-04-23 13:05:04 source > 2022-04-23 13:05:04 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'} 2022-04-23 13:05:07 destination > 2022-04-23 13:05:07 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:07 destination > 2022-04-23 13:05:07 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:08 destination > 2022-04-23 13:05:08 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):295 - Selected loading method is set to: GCS 2022-04-23 13:05:21 source > 2022-04-23 13:05:21 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:21 source > 2022-04-23 13:05:21 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:21 source > 2022-04-23 13:05:21 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:21 source > 2022-04-23 13:05:21 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-23 13:05:21 destination > 2022-04-23 13:05:21 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"AVRO","flattening":"No flattening","part_size_mb":"5"} 2022-04-23 13:05:21 destination > 2022-04-23 13:05:21 INFO i.a.i.d.b.BigQueryUtils(isKeepFilesInGcs):311 - All tmp files will be removed from GCS when replication is finished 2022-04-23 13:05:22 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.credential: is not defined in the schema and the schema does not allow additional properties, $.part_size_mb: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_path: is not defined in the schema and the schema does not allow additional properties, $.keep_files_in_gcs-bucket: is not defined in the schema and the schema does not allow additional properties, $.method: must be a constant value Standard 2022-04-23 13:05:22 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2022-04-23 13:05:22 INFO i.a.w.DefaultReplicationWorker(cancel):377 - Cancelling replication worker... 2022-04-23 13:05:22 source > 2022-04-23 13:05:22 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-04-23 13:05:22 source > 2022-04-23 13:05:22 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-04-23 13:05:22 source > 2022-04-23 13:05:22 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='LocalUser', namespace='tracking'}, New Cursor Field: null. Resetting cursor value 2022-04-23 13:05:22 source > 2022-04-23 13:05:22 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='LocalGroup', namespace='tracking'}, New Cursor Field: null. Resetting cursor value 2022-04-23 13:05:23 destination > 2022-04-23 13:05:23 INFO i.a.i.d.b.BigQueryDestination(getGcsRecordConsumer):287 - Creating BigQuery staging message consumer with staging ID 18701019-aa83-4ce2-89c6-e27d2d7920fb at 2022-04-23T13:05:21.693Z 2022-04-23 13:05:23 destination > 2022-04-23 13:05:23 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(formatAllOfAndAnyOfFields):68 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:23 destination > 2022-04-23 13:05:23 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getSchemaFields):222 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:23 destination > 2022-04-23 13:05:23 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getBigQuerySchema):217 - Airbyte Schema is transformed from {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} to [Field{name=id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=mrr, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=plan, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isMnd, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=quota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=status, type=STRING, mode=null, description=null, policyTags=null}, Field{name=userId, type=STRING, mode=null, description=null, policyTags=null}, Field{name=churned, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=country, type=STRING, mode=null, description=null, policyTags=null}, Field{name=timezone, type=STRING, mode=null, description=null, policyTags=null}, Field{name=apiAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=churnDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=createdAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=updatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=alertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=companyName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=paymentType, type=STRING, mode=null, description=null, policyTags=null}, Field{name=membersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=planCategory, type=STRING, mode=null, description=null, policyTags=null}, Field{name=reportsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=booleanAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=consumedQuota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastApiAccess, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastMrrChange, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=groupCreatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxAlertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_pos, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=commitmentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=fullCountryName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxMembersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=totalPaidAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_file, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxSocialAccount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastMrrChangeDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumed, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRecurrence, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_deleted_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_updated_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=alertsQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=firstDateOfPayment, type=STRING, mode=null, description=null, policyTags=null}, Field{name=socialAccountCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=contractTotalAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=membersQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=consumedQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=daysBeforeQuotaRenew, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumedPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=numberOfScheduledReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]. 2022-04-23 13:05:24 destination > 2022-04-23 13:05:23 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=sql2_tracking_LocalGroup, namespace=tracking, datasetId=tracking, datasetLocation=europe-west1, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_mxl_sql2_tracking_LocalGroup}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalGroup}}, tableSchema=Schema{fields=[Field{name=id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=mrr, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=plan, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isMnd, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=quota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=status, type=STRING, mode=null, description=null, policyTags=null}, Field{name=userId, type=STRING, mode=null, description=null, policyTags=null}, Field{name=churned, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=country, type=STRING, mode=null, description=null, policyTags=null}, Field{name=timezone, type=STRING, mode=null, description=null, policyTags=null}, Field{name=apiAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=churnDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=createdAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=updatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=alertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=companyName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=paymentType, type=STRING, mode=null, description=null, policyTags=null}, Field{name=membersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=planCategory, type=STRING, mode=null, description=null, policyTags=null}, Field{name=reportsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=booleanAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=consumedQuota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastApiAccess, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastMrrChange, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=groupCreatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxAlertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_pos, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=commitmentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=fullCountryName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxMembersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=totalPaidAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_file, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxSocialAccount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastMrrChangeDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumed, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRecurrence, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_deleted_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_updated_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=alertsQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=firstDateOfPayment, type=STRING, mode=null, description=null, policyTags=null}, Field{name=socialAccountCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=contractTotalAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=membersQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=consumedQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=daysBeforeQuotaRenew, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumedPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=numberOfScheduledReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]}, syncMode=append, stagedFiles=[]] 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(formatAllOfAndAnyOfFields):68 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"email":{"type":"string"},"isVip":{"type":"boolean"},"bucket":{"type":"number"},"status":{"type":"string"},"isOwner":{"type":"boolean"},"group_id":{"type":"string"},"language":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"jobPosition":{"type":"string"},"roleInGroup":{"type":"string"},"_ab_cdc_log_pos":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getSchemaFields):222 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"email":{"type":"string"},"isVip":{"type":"boolean"},"bucket":{"type":"number"},"status":{"type":"string"},"isOwner":{"type":"boolean"},"group_id":{"type":"string"},"language":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"jobPosition":{"type":"string"},"roleInGroup":{"type":"string"},"_ab_cdc_log_pos":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getBigQuerySchema):217 - Airbyte Schema is transformed from {"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"email":{"type":"string"},"isVip":{"type":"boolean"},"bucket":{"type":"number"},"status":{"type":"string"},"isOwner":{"type":"boolean"},"group_id":{"type":"string"},"language":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"jobPosition":{"type":"string"},"roleInGroup":{"type":"string"},"_ab_cdc_log_pos":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}} to [Field{name=id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=name, type=STRING, mode=null, description=null, policyTags=null}, Field{name=email, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isVip, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=bucket, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=status, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isOwner, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=group_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=language, type=STRING, mode=null, description=null, policyTags=null}, Field{name=createdAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=updatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=jobPosition, type=STRING, mode=null, description=null, policyTags=null}, Field{name=roleInGroup, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_pos, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_file, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_deleted_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_updated_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]. 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=sql2_tracking_LocalUser, namespace=tracking, datasetId=tracking, datasetLocation=europe-west1, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_wih_sql2_tracking_LocalUser}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalUser}}, tableSchema=Schema{fields=[Field{name=id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=name, type=STRING, mode=null, description=null, policyTags=null}, Field{name=email, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isVip, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=bucket, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=status, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isOwner, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=group_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=language, type=STRING, mode=null, description=null, policyTags=null}, Field{name=createdAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=updatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=jobPosition, type=STRING, mode=null, description=null, policyTags=null}, Field{name=roleInGroup, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_pos, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_file, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_deleted_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_updated_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]}, syncMode=append, stagedFiles=[]] 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):98 - Preparing tmp tables in destination started for 2 streams 2022-04-23 13:05:24 destination > 2022-04-23 13:05:24 INFO i.a.i.d.b.BigQueryGcsOperations(createSchemaIfNotExists):86 - Creating dataset tracking 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column mrr (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column commitmentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column userId (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastFullPushAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column country (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column companyName (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column membersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxMembersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column membersQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column alertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxAlertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column alertsQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column consumedQuota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column consumedQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column quota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column booleanAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column plan (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column groupCreatedAt (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column isMnd (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column reportsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column socialAccountCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxSocialAccount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column apiAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastApiAccess (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column firstDateOfPayment (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column contractTotalAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentRecurrence (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastMrrChangeDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastMrrChange (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column totalPaidAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column churnDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column churned (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column timezone (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column fullCountryName (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column numberOfScheduledReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column daysBeforeQuotaRenew (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastQuotaConsumed (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastQuotaConsumedPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column planCategory (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentType (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column group_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column email (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column jobPosition (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column language (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column isVip (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column bucket (type SMALLINT[5]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column roleInGroup (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column isOwner (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column mrr (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column commitmentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column userId (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column country (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column companyName (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column membersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxMembersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column membersQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column alertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxAlertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column alertsQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column consumedQuota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column consumedQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column quota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column booleanAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column plan (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column groupCreatedAt (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column isMnd (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column reportsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column socialAccountCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxSocialAccount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column apiAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastApiAccess (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column firstDateOfPayment (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column contractTotalAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentRecurrence (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastMrrChangeDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastMrrChange (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column totalPaidAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column churnDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column churned (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column timezone (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column fullCountryName (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column numberOfScheduledReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column daysBeforeQuotaRenew (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastQuotaConsumed (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastQuotaConsumedPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column planCategory (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentType (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column group_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column email (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column jobPosition (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column language (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column isVip (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column bucket (type SMALLINT[5]) -> Json type io.airbyte.protocol.models.JsonSchemaType@62891fc8 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column roleInGroup (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column lastFullPushAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@39c1fe0b 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column isOwner (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@367b22e5 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.s.m.MySqlCdcTargetPosition(targetPosition):61 - Target File position : FileName: mysql-bin.001275, Position : 663866827 2022-04-23 13:05:25 source > 2022-04-23 13:05:25 INFO i.a.i.d.AirbyteDebeziumHandler(getIncrementalIterators):72 - using CDC: true 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO o.a.k.c.c.AbstractConfig(logAll):354 - EmbeddedConfig values: 2022-04-23 13:05:26 source > access.control.allow.methods = 2022-04-23 13:05:26 source > access.control.allow.origin = 2022-04-23 13:05:26 source > admin.listeners = null 2022-04-23 13:05:26 source > bootstrap.servers = [localhost:9092] 2022-04-23 13:05:26 source > client.dns.lookup = use_all_dns_ips 2022-04-23 13:05:26 source > config.providers = [] 2022-04-23 13:05:26 source > connector.client.config.override.policy = None 2022-04-23 13:05:26 source > header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter 2022-04-23 13:05:26 source > internal.key.converter = class org.apache.kafka.connect.json.JsonConverter 2022-04-23 13:05:26 source > internal.value.converter = class org.apache.kafka.connect.json.JsonConverter 2022-04-23 13:05:26 source > key.converter = class org.apache.kafka.connect.json.JsonConverter 2022-04-23 13:05:26 source > listeners = null 2022-04-23 13:05:26 source > metric.reporters = [] 2022-04-23 13:05:26 source > metrics.num.samples = 2 2022-04-23 13:05:26 source > metrics.recording.level = INFO 2022-04-23 13:05:26 source > metrics.sample.window.ms = 30000 2022-04-23 13:05:26 source > offset.flush.interval.ms = 1000 2022-04-23 13:05:26 source > offset.flush.timeout.ms = 5000 2022-04-23 13:05:26 source > offset.storage.file.filename = /tmp/cdc-state-offset10977849571147019934/offset.dat 2022-04-23 13:05:26 source > offset.storage.partitions = null 2022-04-23 13:05:26 source > offset.storage.replication.factor = null 2022-04-23 13:05:26 source > offset.storage.topic = 2022-04-23 13:05:26 source > plugin.path = null 2022-04-23 13:05:26 source > response.http.headers.config = 2022-04-23 13:05:26 source > rest.advertised.host.name = null 2022-04-23 13:05:26 source > rest.advertised.listener = null 2022-04-23 13:05:26 source > rest.advertised.port = null 2022-04-23 13:05:26 source > rest.extension.classes = [] 2022-04-23 13:05:26 source > rest.host.name = null 2022-04-23 13:05:26 source > rest.port = 8083 2022-04-23 13:05:26 source > ssl.cipher.suites = null 2022-04-23 13:05:26 source > ssl.client.auth = none 2022-04-23 13:05:26 source > ssl.enabled.protocols = [TLSv1.2, TLSv1.3] 2022-04-23 13:05:26 source > ssl.endpoint.identification.algorithm = https 2022-04-23 13:05:26 source > ssl.engine.factory.class = null 2022-04-23 13:05:26 source > ssl.key.password = null 2022-04-23 13:05:26 source > ssl.keymanager.algorithm = SunX509 2022-04-23 13:05:26 source > ssl.keystore.location = null 2022-04-23 13:05:26 source > ssl.keystore.password = null 2022-04-23 13:05:26 source > ssl.keystore.type = JKS 2022-04-23 13:05:26 source > ssl.protocol = TLSv1.3 2022-04-23 13:05:26 source > ssl.provider = null 2022-04-23 13:05:26 source > ssl.secure.random.implementation = null 2022-04-23 13:05:26 source > ssl.trustmanager.algorithm = PKIX 2022-04-23 13:05:26 source > ssl.truststore.location = null 2022-04-23 13:05:26 source > ssl.truststore.password = null 2022-04-23 13:05:26 source > ssl.truststore.type = JKS 2022-04-23 13:05:26 source > task.shutdown.graceful.timeout.ms = 5000 2022-04-23 13:05:26 source > topic.creation.enable = true 2022-04-23 13:05:26 source > topic.tracking.allow.reset = true 2022-04-23 13:05:26 source > topic.tracking.enable = true 2022-04-23 13:05:26 source > value.converter = class org.apache.kafka.connect.json.JsonConverter 2022-04-23 13:05:26 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: unknown found, object expected 2022-04-23 13:05:26 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN o.a.k.c.r.WorkerConfig(logPluginPathConfigProviderWarning):420 - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2022-04-23 13:05:26 destination > 2022-04-23 13:05:26 INFO i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_mxl_sql2_tracking_LocalGroup}} 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(start):100 - Starting MySqlConnectorTask with configuration: 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - connector.class = io.debezium.connector.mysql.MySqlConnector 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - snapshot.locking.mode = none 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - max.queue.size = 8192 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - include.schema.changes = false 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - binary.handling.mode = base64 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - offset.storage.file.filename = /tmp/cdc-state-offset10977849571147019934/offset.dat 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - decimal.handling.mode = string 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - converters = boolean, datetime 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - datetime.type = io.airbyte.integrations.debezium.internals.MySQLConverter 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.history.file.filename = /tmp/cdc-db-history11270383150955141107/dbhistory.dat 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.user = airbyte-ro 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.dbname = tracking 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - boolean.type = io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.server.name = tracking 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.port = 3306 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - offset.flush.interval.ms = 1000 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - key.converter.schemas.enable = false 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.hostname = sql2-x.mention.net 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.password = ******** 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - name = tracking 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - value.converter.schemas.enable = false 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - max.batch.size = 2048 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - table.include.list = tracking.LocalGroup,tracking.LocalUser 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - snapshot.mode = initial 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.history = io.airbyte.integrations.debezium.internals.FilteredFileDatabaseHistory 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 INFO i.d.c.c.BaseSourceTask(lambda$start$0):102 - database.include.list = tracking 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. 2022-04-23 13:05:26 source > 2022-04-23 13:05:26 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. 2022-04-23 13:05:26 destination > 2022-04-23 13:05:26 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_mxl_sql2_tracking_LocalGroup}} 2022-04-23 13:05:26 destination > 2022-04-23 13:05:26 INFO i.a.i.d.b.BigQueryGcsOperations(createStageIfNotExists):101 - Creating staging path for stream sql2_tracking_LocalGroup (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.MySqlConnectorTask(start):168 - Found no existing offset, so preparing to perform a snapshot 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):94 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ does not exist in bucket; creating... 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.u.Threads(threadFactory):270 - Requested thread factory for connector MySqlConnector, id = tracking named = binlog-client 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.u.Threads(threadFactory):270 - Requested thread factory for connector MySqlConnector, id = tracking named = snapshot 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.u.Threads$3(newThread):287 - Creating thread debezium-mysqlconnector-tracking-snapshot 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):248 - Starting snapshot for jdbc:mysql://sql2-x.mention.net:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'airbyte-ro' with locking mode 'none' 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(logRolesForCurrentUser):1021 - Snapshot is using user 'airbyte-ro' with these MySQL grants: 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logRolesForCurrentUser$21):1022 - GRANT RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'airbyte-ro'@'51.77.229.216' 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logRolesForCurrentUser$21):1022 - GRANT SELECT ON `tracking`.* TO 'airbyte-ro'@'51.77.229.216' 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(logServerInformation):992 - MySQL server variables related to change data capture: 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_cache_size = 32768 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_checksum = CRC32 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_direct_non_transactional_updates = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_error_action = ABORT_SERVER 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_format = ROW 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_group_commit_sync_delay = 0 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_group_commit_sync_no_delay_count = 0 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_gtid_simple_recovery = ON 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_max_flush_queue_time = 0 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_order_commits = ON 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_row_image = FULL 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_rows_query_log_events = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_skip_flush_commands = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_space_limit = 0 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_stmt_cache_size = 32768 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_transaction_dependency_history_size = 25000 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - binlog_transaction_dependency_tracking = COMMIT_ORDER 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_client = utf8mb4 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_connection = utf8mb4 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_database = latin1 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_filesystem = binary 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_results = utf8mb4 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_server = latin1 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_set_system = utf8 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - character_sets_dir = /usr/share/mysql/charsets/ 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - collation_connection = utf8mb4_general_ci 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - collation_database = latin1_swedish_ci 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - collation_server = latin1_swedish_ci 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - encrypt_binlog = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - enforce_gtid_consistency = ON 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - gtid_executed_compression_period = 1000 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - gtid_mode = ON 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - gtid_next = AUTOMATIC 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - gtid_owned = 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - gtid_purged = 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324, 2022-04-23 13:05:27 source > 9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392, 2022-04-23 13:05:27 source > a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-375598955, 2022-04-23 13:05:27 source > e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - have_backup_safe_binlog_info = YES 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - innodb_api_enable_binlog = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - innodb_locks_unsafe_for_binlog = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - innodb_version = 5.7.27-30 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - log_statements_unsafe_for_binlog = ON 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - max_binlog_cache_size = 18446744073709547520 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - max_binlog_files = 0 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - max_binlog_size = 1073741824 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - max_binlog_stmt_cache_size = 18446744073709547520 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - protocol_version = 10 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - session_track_gtids = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - slave_type_conversions = 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - sync_binlog = 1 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - system_time_zone = UTC 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - time_zone = SYSTEM 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - tls_version = TLSv1.2 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - tx_isolation = REPEATABLE-READ 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - tx_read_only = OFF 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - version = 5.7.27-30-log 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - version_comment = Percona Server (GPL), Release '30', Revision '8916819' 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - version_compile_machine = x86_64 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - version_compile_os = debian-linux-gnu 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - version_suffix = -log 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):282 - Step 0: disabling autocommit, enabling repeatable read transactions, and setting lock wait timeout to 10 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):96 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ has been created in bucket. 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_wih_sql2_tracking_LocalUser}} 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):342 - Step 2: start transaction with consistent snapshot 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):367 - Step 3: read list of available databases 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):375 - list of available databases is: [information_schema, email, heartbeat, klout, mysql, old_genders, old_genders2, old_sentiment, old_zabbix2, performance_schema, stats, sys, test, tracking, zabbix2] 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):386 - Step 4: read list of available tables in each database 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_wih_sql2_tracking_LocalUser}} 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.b.BigQueryGcsOperations(createStageIfNotExists):101 - Creating staging path for stream sql2_tracking_LocalUser (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):407 - including 'tracking.LocalGroup' among known tables 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):414 - including 'tracking.LocalGroup' for further processing 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):407 - including 'tracking.LocalUser' among known tables 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):414 - including 'tracking.LocalUser' for further processing 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):407 - including 'tracking.SegmentGroup' among known tables 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):417 - 'tracking.SegmentGroup' is filtered out of capturing 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):407 - including 'tracking.SegmentUser' among known tables 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$execute$4):417 - 'tracking.SegmentUser' is filtered out of capturing 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):448 - snapshot continuing with database(s): [tracking] 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(readBinlogPosition):906 - Step 5: read binlog position of MySQL primary server 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):94 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ does not exist in bucket; creating... 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(lambda$readBinlogPosition$18):918 - using binlog 'mysql-bin.001275' at position '663906440' and gtid '7fd08196-a72e-11e6-9505-0cc47a419f60:1-324, 2022-04-23 13:05:27 source > 9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392, 2022-04-23 13:05:27 source > a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-398511416, 2022-04-23 13:05:27 source > e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989' 2022-04-23 13:05:27 source > 2022-04-23 13:05:27 INFO i.d.c.m.SnapshotReader(execute):494 - Step 6: generating DROP and CREATE statements to reflect current database schemas: 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):96 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/23/13/18701019-aa83-4ce2-89c6-e27d2d7920fb/ has been created in bucket. 2022-04-23 13:05:27 destination > 2022-04-23 13:05:27 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):107 - Preparing tmp tables in destination completed. 2022-04-23 13:05:28 source > 2022-04-23 13:05:28 INFO i.d.c.m.SnapshotReader(execute):595 - Step 7: scanning contents of 2 tables while still in transaction 2022-04-23 13:05:29 source > 2022-04-23 13:05:29 INFO i.d.c.m.SnapshotReader(execute):646 - Step 7: - scanning table 'tracking.LocalGroup' (1 of 2 tables) 2022-04-23 13:05:29 source > 2022-04-23 13:05:29 INFO i.d.c.m.SnapshotReader(execute):651 - For table 'tracking.LocalGroup' using select statement: 'SELECT * FROM `tracking`.`LocalGroup`' 2022-04-23 13:05:29 destination > 2022-04-23 13:05:29 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream sql2_tracking_LocalGroup (current state: 0 bytes in 0 buffers) 2022-04-23 13:05:29 destination > 2022-04-23 13:05:29 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(formatAllOfAndAnyOfFields):68 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:30 destination > 2022-04-23 13:05:30 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getSchemaFields):222 - getSchemaFields : {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@5eb2172 2022-04-23 13:05:30 destination > 2022-04-23 13:05:30 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getBigQuerySchema):217 - Airbyte Schema is transformed from {"type":"object","properties":{"id":{"type":"string"},"mrr":{"type":"number"},"plan":{"type":"string"},"isMnd":{"type":"boolean"},"quota":{"type":"number"},"status":{"type":"string"},"userId":{"type":"string"},"churned":{"type":"boolean"},"country":{"type":"string"},"timezone":{"type":"string"},"apiAccess":{"type":"boolean"},"churnDate":{"type":"string"},"createdAt":{"type":"string"},"updatedAt":{"type":"string"},"maxReports":{"type":"number"},"alertsCount":{"type":"number"},"companyName":{"type":"string"},"paymentType":{"type":"string"},"membersCount":{"type":"number"},"paymentRenew":{"type":"string"},"planCategory":{"type":"string"},"reportsCount":{"type":"number"},"booleanAccess":{"type":"boolean"},"consumedQuota":{"type":"number"},"lastApiAccess":{"type":"string"},"lastMrrChange":{"type":"number"},"groupCreatedAt":{"type":"string"},"maxAlertsCount":{"type":"number"},"_ab_cdc_log_pos":{"type":"number"},"commitmentRenew":{"type":"string"},"fullCountryName":{"type":"string"},"maxMembersCount":{"type":"number"},"totalPaidAmount":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"maxSocialAccount":{"type":"number"},"lastMrrChangeDate":{"type":"string"},"lastQuotaConsumed":{"type":"number"},"paymentRecurrence":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"alertsQuotaPercent":{"type":"number"},"firstDateOfPayment":{"type":"string"},"socialAccountCount":{"type":"number"},"contractTotalAmount":{"type":"number"},"membersQuotaPercent":{"type":"number"},"consumedQuotaPercent":{"type":"number"},"daysBeforeQuotaRenew":{"type":"number"},"lastQuotaConsumedPercent":{"type":"number"},"numberOfScheduledReports":{"type":"number"}}} to [Field{name=id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=mrr, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=plan, type=STRING, mode=null, description=null, policyTags=null}, Field{name=isMnd, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=quota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=status, type=STRING, mode=null, description=null, policyTags=null}, Field{name=userId, type=STRING, mode=null, description=null, policyTags=null}, Field{name=churned, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=country, type=STRING, mode=null, description=null, policyTags=null}, Field{name=timezone, type=STRING, mode=null, description=null, policyTags=null}, Field{name=apiAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=churnDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=createdAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=updatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=alertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=companyName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=paymentType, type=STRING, mode=null, description=null, policyTags=null}, Field{name=membersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=planCategory, type=STRING, mode=null, description=null, policyTags=null}, Field{name=reportsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=booleanAccess, type=BOOLEAN, mode=null, description=null, policyTags=null}, Field{name=consumedQuota, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastApiAccess, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastMrrChange, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=groupCreatedAt, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxAlertsCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_pos, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=commitmentRenew, type=STRING, mode=null, description=null, policyTags=null}, Field{name=fullCountryName, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxMembersCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=totalPaidAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_log_file, type=STRING, mode=null, description=null, policyTags=null}, Field{name=maxSocialAccount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastMrrChangeDate, type=STRING, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumed, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=paymentRecurrence, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_deleted_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_ab_cdc_updated_at, type=STRING, mode=null, description=null, policyTags=null}, Field{name=alertsQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=firstDateOfPayment, type=STRING, mode=null, description=null, policyTags=null}, Field{name=socialAccountCount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=contractTotalAmount, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=membersQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=consumedQuotaPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=daysBeforeQuotaRenew, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=lastQuotaConsumedPercent, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=numberOfScheduledReports, type=FLOAT, mode=null, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]. 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(cancel):385 - Cancelling destination... 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete. 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(cancel):392 - Cancelling source... 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-04-23 13:05:32 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-04-23 13:05:32 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-04-23 13:05:32 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:167) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: java.io.IOException: Stream closed at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?] at java.io.OutputStream.write(OutputStream.java:162) ~[?:?] at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-23 13:05:32 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2022-04-23 13:05:32 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2022-04-23 13:05:32 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled. 2022-04-23 13:05:32 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-23 13:05:32 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-23 13:05:32 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=d6cf2073-d03d-3686-9c9a-cd8cc5c138a6, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:106) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:53) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-04-23 13:05:32 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled. 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@520f0bb6[status=cancelled,recordsSynced=518,bytesSynced=632899,startTime=1650719012745,endTime=1650719132955,totalStats=io.airbyte.config.SyncStats@6967489e[recordsEmitted=518,bytesEmitted=632899,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@7a8b7f5d[streamName=sql2_tracking_LocalGroup,stats=io.airbyte.config.SyncStats@164b01ca[recordsEmitted=518,bytesEmitted=632899,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-23 13:05:32 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-23 13:05:32 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.