2022-04-26 08:54:17 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha
2022-04-26 08:54:17 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/10/0/logs.log
2022-04-26 08:54:17 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha
2022-04-26 08:54:17 [32mINFO[m i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 10 attempt id: 0
2022-04-26 08:54:17 [32mINFO[m i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {tracking.LocalUser=incremental - append, tracking.LocalGroup=incremental - append}
2022-04-26 08:54:17 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-26 08:54:17 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery-denormalized:0.3.1 exists...
2022-04-26 08:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery-denormalized:0.3.1 was found locally.
2022-04-26 08:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 10
2022-04-26 08:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/10/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery-denormalized:0.3.1 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=10 airbyte/destination-bigquery-denormalized:0.3.1 write --config destination_config.json --catalog destination_catalog.json
2022-04-26 08:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.6 exists...
2022-04-26 08:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.6 was found locally.
2022-04-26 08:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 10
2022-04-26 08:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/10/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.6 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=10 airbyte/source-mysql:0.5.6 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-26 08:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-26 08:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-26 08:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-26 08:54:18 [44msource[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-26 08:54:18 [44msource[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-26 08:54:18 [44msource[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-26 08:54:18 [44msource[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-26 08:54:18 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-26 08:54:18 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-26 08:54:18 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-26 08:54:18 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-26 08:54:18 [44msource[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-26 08:54:18 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.s.m.MySqlSource(main):206 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-04-26 08:54:19 [43mdestination[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: c94fdbb8fc5b46a28f25d4ff3603d849
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
2022-04-26 08:54:19 [43mdestination[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination
2022-04-26 08:54:19 [43mdestination[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-26 08:54:19 [44msource[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-04-26 08:54:19 [43mdestination[0m > 2022-04-26 08:54:19 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-26 08:54:20 [43mdestination[0m > 2022-04-26 08:54:20 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-26 08:54:20 [43mdestination[0m > 2022-04-26 08:54:20 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-26 08:54:20 [43mdestination[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.d.b.BigQueryUtils(getLoadingMethod):295 - Selected loading method is set to: GCS
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [33mWARN[m 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-26 08:54:20 [43mdestination[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"AVRO","flattening":"No flattening","part_size_mb":"5"}
2022-04-26 08:54:20 [43mdestination[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.d.b.BigQueryUtils(isKeepFilesInGcs):311 - All tmp files will be removed from GCS when replication is finished
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: io.airbyte.integrations.source.relationaldb.models.CdcState@2237bada[state={"mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650962504,\"file\":\"mysql-bin.001283\",\"pos\":1046039710,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"},"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n"},additionalProperties={}]
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.s.r.StateManager(createCursorInfoForStream):108 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='LocalUser', namespace='tracking'}. Cursor Field: null Value: null
2022-04-26 08:54:20 [44msource[0m > 2022-04-26 08:54:20 [32mINFO[m i.a.i.s.r.StateManager(createCursorInfoForStream):108 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='LocalGroup', namespace='tracking'}. Cursor Field: null Value: null
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.d.b.BigQueryDestination(getGcsRecordConsumer):287 - Creating BigQuery staging message consumer with staging ID c5a9ca7a-4f23-4be2-99c4-d5fb16b18247 at 2022-04-26T08:54:20.429Z
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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@43f0c2d1
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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@43f0c2d1
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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_zmh_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-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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@43f0c2d1
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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@43f0c2d1
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m 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_ryt_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-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):98 - Preparing tmp tables in destination started for 2 streams
2022-04-26 08:54:21 [43mdestination[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(createSchemaIfNotExists):86 - Creating dataset tracking
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column mrr (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column commitmentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column userId (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastFullPushAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column country (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column companyName (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column membersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxMembersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column membersQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column alertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxAlertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column alertsQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column consumedQuota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column consumedQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column quota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column booleanAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column plan (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column groupCreatedAt (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column isMnd (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column reportsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column socialAccountCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column maxSocialAccount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column apiAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastApiAccess (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column firstDateOfPayment (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column contractTotalAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentRecurrence (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastMrrChangeDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastMrrChange (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column totalPaidAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column churnDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column churned (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column timezone (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column fullCountryName (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column numberOfScheduledReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column daysBeforeQuotaRenew (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastQuotaConsumed (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column lastQuotaConsumedPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column planCategory (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentGroup column paymentType (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m 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@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column email (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column jobPosition (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column language (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column isVip (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column bucket (type SMALLINT[5]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column roleInGroup (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalUser column isOwner (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column mrr (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column commitmentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column userId (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentRenew (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column country (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column companyName (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column membersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxMembersCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column membersQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column alertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxAlertsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column alertsQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column consumedQuota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column consumedQuotaPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column quota (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column booleanAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column plan (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column groupCreatedAt (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column isMnd (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column reportsCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column socialAccountCount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column maxSocialAccount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column apiAccess (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastApiAccess (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column firstDateOfPayment (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column contractTotalAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentRecurrence (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastMrrChangeDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastMrrChange (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column totalPaidAmount (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column churnDate (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column churned (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column timezone (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column fullCountryName (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column numberOfScheduledReports (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column daysBeforeQuotaRenew (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastQuotaConsumed (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column lastQuotaConsumedPercent (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column planCategory (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table LocalGroup column paymentType (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column id (type VARCHAR[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column status (type VARCHAR[20]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m 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@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column createdAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column updatedAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column email (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column jobPosition (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column language (type VARCHAR[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column isVip (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column bucket (type SMALLINT[5]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column roleInGroup (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column lastFullPushAt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4bbb49b0
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SegmentUser column isOwner (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41f4fe5
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.m.MySqlCdcTargetPosition(targetPosition):61 - Target File position : FileName: mysql-bin.001283, Position : 1046596688
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.s.m.h.CdcConfigurationHelper(lambda$checkBinlog$0):50 - Binlog mysql-bin.001283 is available
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.a.i.d.AirbyteDebeziumHandler(getIncrementalIterators):72 - using CDC: true
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m o.a.k.c.c.AbstractConfig(logAll):354 - EmbeddedConfig values: 
2022-04-26 08:54:21 [44msource[0m > 	access.control.allow.methods = 
2022-04-26 08:54:21 [44msource[0m > 	access.control.allow.origin = 
2022-04-26 08:54:21 [44msource[0m > 	admin.listeners = null
2022-04-26 08:54:21 [44msource[0m > 	bootstrap.servers = [localhost:9092]
2022-04-26 08:54:21 [44msource[0m > 	client.dns.lookup = use_all_dns_ips
2022-04-26 08:54:21 [44msource[0m > 	config.providers = []
2022-04-26 08:54:21 [44msource[0m > 	connector.client.config.override.policy = None
2022-04-26 08:54:21 [44msource[0m > 	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
2022-04-26 08:54:21 [44msource[0m > 	internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
2022-04-26 08:54:21 [44msource[0m > 	internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
2022-04-26 08:54:21 [44msource[0m > 	key.converter = class org.apache.kafka.connect.json.JsonConverter
2022-04-26 08:54:21 [44msource[0m > 	listeners = null
2022-04-26 08:54:21 [44msource[0m > 	metric.reporters = []
2022-04-26 08:54:21 [44msource[0m > 	metrics.num.samples = 2
2022-04-26 08:54:21 [44msource[0m > 	metrics.recording.level = INFO
2022-04-26 08:54:21 [44msource[0m > 	metrics.sample.window.ms = 30000
2022-04-26 08:54:21 [44msource[0m > 	offset.flush.interval.ms = 1000
2022-04-26 08:54:21 [44msource[0m > 	offset.flush.timeout.ms = 5000
2022-04-26 08:54:21 [44msource[0m > 	offset.storage.file.filename = /tmp/cdc-state-offset1427940652577391568/offset.dat
2022-04-26 08:54:21 [44msource[0m > 	offset.storage.partitions = null
2022-04-26 08:54:21 [44msource[0m > 	offset.storage.replication.factor = null
2022-04-26 08:54:21 [44msource[0m > 	offset.storage.topic = 
2022-04-26 08:54:21 [44msource[0m > 	plugin.path = null
2022-04-26 08:54:21 [44msource[0m > 	response.http.headers.config = 
2022-04-26 08:54:21 [44msource[0m > 	rest.advertised.host.name = null
2022-04-26 08:54:21 [44msource[0m > 	rest.advertised.listener = null
2022-04-26 08:54:21 [44msource[0m > 	rest.advertised.port = null
2022-04-26 08:54:21 [44msource[0m > 	rest.extension.classes = []
2022-04-26 08:54:21 [44msource[0m > 	rest.host.name = null
2022-04-26 08:54:21 [44msource[0m > 	rest.port = 8083
2022-04-26 08:54:21 [44msource[0m > 	ssl.cipher.suites = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.client.auth = none
2022-04-26 08:54:21 [44msource[0m > 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2022-04-26 08:54:21 [44msource[0m > 	ssl.endpoint.identification.algorithm = https
2022-04-26 08:54:21 [44msource[0m > 	ssl.engine.factory.class = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.key.password = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.keymanager.algorithm = SunX509
2022-04-26 08:54:21 [44msource[0m > 	ssl.keystore.location = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.keystore.password = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.keystore.type = JKS
2022-04-26 08:54:21 [44msource[0m > 	ssl.protocol = TLSv1.3
2022-04-26 08:54:21 [44msource[0m > 	ssl.provider = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.secure.random.implementation = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.trustmanager.algorithm = PKIX
2022-04-26 08:54:21 [44msource[0m > 	ssl.truststore.location = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.truststore.password = null
2022-04-26 08:54:21 [44msource[0m > 	ssl.truststore.type = JKS
2022-04-26 08:54:21 [44msource[0m > 	task.shutdown.graceful.timeout.ms = 5000
2022-04-26 08:54:21 [44msource[0m > 	topic.creation.enable = true
2022-04-26 08:54:21 [44msource[0m > 	topic.tracking.allow.reset = true
2022-04-26 08:54:21 [44msource[0m > 	topic.tracking.enable = true
2022-04-26 08:54:21 [44msource[0m > 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2022-04-26 08:54:21 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $: unknown found, object expected
2022-04-26 08:54:21 [1;31mERROR[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(start):100 - Starting MySqlConnectorTask with configuration:
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    connector.class = io.debezium.connector.mysql.MySqlConnector
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    snapshot.locking.mode = none
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    max.queue.size = 8192
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    include.schema.changes = false
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    binary.handling.mode = base64
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    offset.storage.file.filename = /tmp/cdc-state-offset1427940652577391568/offset.dat
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    decimal.handling.mode = string
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    converters = boolean, datetime
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    datetime.type = io.airbyte.integrations.debezium.internals.MySQLConverter
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.history.file.filename = /tmp/cdc-db-history13547442609495716527/dbhistory.dat
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.user = airbyte-ro
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.dbname = tracking
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    boolean.type = io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.server.name = tracking
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.port = 3306
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    offset.flush.interval.ms = 1000
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    key.converter.schemas.enable = false
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.hostname = sql2-x.mention.net
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.password = ********
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    name = tracking
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    value.converter.schemas.enable = false
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    max.batch.size = 2048
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    table.include.list = tracking.LocalGroup,tracking.LocalUser
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    snapshot.mode = initial
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.history = io.airbyte.integrations.debezium.internals.FilteredFileDatabaseHistory
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [32mINFO[m i.d.c.c.BaseSourceTask(lambda$start$0):102 -    database.include.list = tracking
2022-04-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:21 [44msource[0m > 2022-04-26 08:54:21 [33mWARN[m 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-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlConnectorTask(start):82 - Found existing offset: {ts_sec=1650962504, file=mysql-bin.001283, pos=1046039710, gtids=7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989, row=1, server_id=1000000023, event=2}
2022-04-26 08:54:22 [43mdestination[0m > 2022-04-26 08:54:22 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}}
2022-04-26 08:54:22 [43mdestination[0m > 2022-04-26 08:54:22 [32mINFO[m i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}}
2022-04-26 08:54:22 [43mdestination[0m > 2022-04-26 08:54:22 [32mINFO[m 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/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlConnectorTask(isBinlogAvailable):519 - MySQL current GTID set 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591421,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989 does contain the GTID set required by the connector 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlConnectorTask(isBinlogAvailable):524 - GTIDs known by the server but not processed yet a9af7dc8-fb5f-11eb-94b0-d05099d23f90:405590615-405591421, for replication are available only a9af7dc8-fb5f-11eb-94b0-d05099d23f90:405590615-405591421
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.u.Threads(threadFactory):270 - Requested thread factory for connector MySqlConnector, id = tracking named = binlog-client
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.BinlogReader(doStart):367 - GTID set purged on server: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-380875729,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):299 - Attempting to generate a filtered GTID set
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):300 - GTID set from previous recorded offset: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):307 - GTID set available on server: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591421,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):313 - Using first available positions for new GTID channels
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):315 - Relevant GTID set available on server: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591421,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.MySqlTaskContext(filterGtidSet):326 - Final merged GTID set to use when connecting to MySQL: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.BinlogReader(doStart):372 - Registering binlog reader with GTID set: 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.u.Threads$3(newThread):287 - Creating thread debezium-mysqlconnector-tracking-binlog-client
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.u.Threads$3(newThread):287 - Creating thread debezium-mysqlconnector-tracking-binlog-client
2022-04-26 08:54:22 [44msource[0m > Apr 26, 2022 8:54:22 AM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2022-04-26 08:54:22 [44msource[0m > INFO: Connected to sql2-x.mention.net:3306 at 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989 (sid:6177, cid:614350539)
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.BinlogReader$ReaderThreadLifecycleListener(onConnect):1128 - Connected to MySQL binlog at sql2-x.mention.net:3306, starting at GTIDs 7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405590614,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989 and binlog file 'mysql-bin.001283', pos=1046039710, skipping 2 events plus 1 rows
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.c.m.BinlogReader(doStart):415 - Waiting for keepalive thread to start
2022-04-26 08:54:22 [44msource[0m > 2022-04-26 08:54:22 [32mINFO[m i.d.u.Threads$3(newThread):287 - Creating thread debezium-mysqlconnector-tracking-binlog-client
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):94 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/ does not exist in bucket; creating...
2022-04-26 08:54:23 [44msource[0m > 2022-04-26 08:54:23 [32mINFO[m i.d.c.m.BinlogReader(doStart):422 - Keepalive thread is running
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):96 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/ has been created in bucket.
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}}
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}}
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m 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/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):94 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/ does not exist in bucket; creating...
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):96 - Storage Object mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/ has been created in bucket.
2022-04-26 08:54:23 [43mdestination[0m > 2022-04-26 08:54:23 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):107 - Preparing tmp tables in destination completed.
2022-04-26 08:55:23 [44msource[0m > 2022-04-26 08:55:23 [32mINFO[m i.a.i.d.i.DebeziumRecordIterator(computeNext):78 - Closing cause next is returned as null
2022-04-26 08:55:23 [44msource[0m > 2022-04-26 08:55:23 [32mINFO[m i.d.e.EmbeddedEngine(stop):996 - Stopping the embedded engine
2022-04-26 08:55:23 [44msource[0m > 2022-04-26 08:55:23 [32mINFO[m i.d.e.EmbeddedEngine(stop):1004 - Waiting for PT5M for connector to stop
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.c.BaseSourceTask(stop):192 - Stopping down connector
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.MySqlConnectorTask(doStop):453 - Stopping MySQL connector task
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.ChainedReader(stop):121 - ChainedReader: Stopping the binlog reader
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.AbstractReader(stop):140 - Discarding 0 unsent record(s) due to the connector shutting down
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.AbstractReader(stop):140 - Discarding 0 unsent record(s) due to the connector shutting down
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.BinlogReader$ReaderThreadLifecycleListener(lambda$onDisconnect$0):1113 - Stopped reading binlog after 6 events, last recorded offset: {ts_sec=1650963257, file=mysql-bin.001283, pos=1046594265, gtids=7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989, row=1, server_id=1000000023, event=2}
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.j.JdbcConnection(lambda$doClose$3):945 - Connection gracefully closed
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.d.c.m.MySqlConnectorTask(completeReaders):491 - Connector task finished all work and is now shutdown
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.d.i.DebeziumRecordPublisher(lambda$start$1):85 - Debezium engine shutdown.
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.d.i.DebeziumRecordIterator(computeNext):80 - no record found. polling again.
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.s.m.MySqlCdcStateHandler(saveState):41 - debezium state: {"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n","mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650963257,\"file\":\"mysql-bin.001283\",\"pos\":1046594265,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"}}
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-26 08:55:24 [44msource[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.s.m.MySqlSource(main):208 - completed source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream sql2_tracking_LocalUser (current state: 0 bytes in 0 buffers)
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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@43f0c2d1
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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@43f0c2d1
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream sql2_tracking_LocalGroup (current state: 0 bytes in 1 buffers)
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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@43f0c2d1
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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@43f0c2d1
2022-04-26 08:55:24 [43mdestination[0m > 2022-04-26 08:55:24 [32mINFO[m 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-26 08:55:25 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 7 (5 KB)
2022-04-26 08:55:25 [32mINFO[m i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 2 current buffers (0 bytes in total)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream sql2_tracking_LocalGroup (3 KB)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$flushBufferFunction$4):115 - Flushing buffer for stream sql2_tracking_LocalGroup (3 KB) to staging
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 23b32b38-d9b3-4e33-b944-a9cbdcf977d72779573340986908445.avro (5 KB)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(uploadRecordsToStage):108 - Uploading records to staging for stream sql2_tracking_LocalGroup (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 5 MB
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with full ID ABPnzm4g3XZkElKMV_YC33B-VMZPbLOzsZu5vf-nb9ufn1yrEqZnaX9rPmFjU6MfyaWVsOZg
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(complete):367 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm4g3...fyaWVsOZg]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm4g3...fyaWVsOZg]: Finished uploading [Part number 1 containing 0.00 MB]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(complete):395 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm4g3...fyaWVsOZg]: Completed
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.s.S3StorageOperations(loadDataIntoBucket):161 - Uploaded buffer file to storage: 23b32b38-d9b3-4e33-b944-a9cbdcf977d72779573340986908445.avro -> airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro (filename: 1.avro)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryWriteConfig(addStagedFile):53 - Added staged file: 1.avro
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 23b32b38-d9b3-4e33-b944-a9cbdcf977d72779573340986908445.avro
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream sql2_tracking_LocalUser (1 KB)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$flushBufferFunction$4):115 - Flushing buffer for stream sql2_tracking_LocalUser (1 KB) to staging
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to f3b8d328-a4fa-4174-80a3-3e7f2e6698f811784837839742819358.avro (2 KB)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(uploadRecordsToStage):108 - Uploading records to staging for stream sql2_tracking_LocalUser (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 5 MB
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with full ID ABPnzm7YbAqzjBS9kPva_5lYKJ4LQRUmSxxJTz9cBVrA3yFCj8Hp3lQA0I66tBGBEEgniUII
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(complete):367 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm7Yb...BEEgniUII]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm7Yb...BEEgniUII]: Finished uploading [Part number 1 containing 0.00 MB]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m a.m.s.StreamTransferManager(complete):395 - [Manager uploading to mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro with id ABPnzm7Yb...BEEgniUII]: Completed
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.s.S3StorageOperations(loadDataIntoBucket):161 - Uploaded buffer file to storage: f3b8d328-a4fa-4174-80a3-3e7f2e6698f811784837839742819358.avro -> airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro (filename: 1.avro)
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryWriteConfig(addStagedFile):53 - Added staged file: 1.avro
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data f3b8d328-a4fa-4174-80a3-3e7f2e6698f811784837839742819358.avro
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream sql2_tracking_LocalGroup
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream sql2_tracking_LocalUser
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):137 - Copying into tables in destination started for 2 streams
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(copyIntoTmpTableFromStage):122 - Uploading records from staging files to tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} (dataset tracking): [1.avro]
2022-04-26 08:55:25 [43mdestination[0m > 2022-04-26 08:55:25 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):126 - Uploading staged file: gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro
2022-04-26 08:55:26 [43mdestination[0m > 2022-04-26 08:55:26 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):135 - [JobId{project=data-stack-dev, job=1110838f-02a3-40fe-828b-fc25ddbaeba4, location=europe-west1}] Created a new job to upload records to tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} (dataset tracking): Job{job=JobId{project=data-stack-dev, job=1110838f-02a3-40fe-828b-fc25ddbaeba4, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963326168, endTime=null, startTime=1650963326312, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=1ubLxjCEysevi/7DiiGXTA==, generatedId=data-stack-dev:europe-west1.1110838f-02a3-40fe-828b-fc25ddbaeba4, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/1110838f-02a3-40fe-828b-fc25ddbaeba4?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}
2022-04-26 08:55:26 [43mdestination[0m > 2022-04-26 08:55:26 [32mINFO[m i.a.i.d.b.BigQueryUtils(waitForJobFinish):319 - Waiting for job finish Job{job=JobId{project=data-stack-dev, job=1110838f-02a3-40fe-828b-fc25ddbaeba4, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963326168, endTime=null, startTime=1650963326312, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=1ubLxjCEysevi/7DiiGXTA==, generatedId=data-stack-dev:europe-west1.1110838f-02a3-40fe-828b-fc25ddbaeba4, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/1110838f-02a3-40fe-828b-fc25ddbaeba4?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-26 08:55:29 [43mdestination[0m > 2022-04-26 08:55:29 [32mINFO[m i.a.i.d.b.BigQueryUtils(waitForJobFinish):321 - Job finish Job{job=JobId{project=data-stack-dev, job=1110838f-02a3-40fe-828b-fc25ddbaeba4, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963326168, endTime=null, startTime=1650963326312, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=1ubLxjCEysevi/7DiiGXTA==, generatedId=data-stack-dev:europe-west1.1110838f-02a3-40fe-828b-fc25ddbaeba4, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/1110838f-02a3-40fe-828b-fc25ddbaeba4?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-26 08:55:29 [43mdestination[0m > 2022-04-26 08:55:29 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):139 - [JobId{project=data-stack-dev, job=1110838f-02a3-40fe-828b-fc25ddbaeba4, location=europe-west1}] Tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} (dataset tracking) is successfully appended with staging files
2022-04-26 08:55:29 [43mdestination[0m > 2022-04-26 08:55:29 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(copyIntoTargetTable):162 - Copying data from tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} to target table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalGroup}} (dataset tracking, sync mode append)
2022-04-26 08:55:33 [43mdestination[0m > 2022-04-26 08:55:33 [32mINFO[m i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):185 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalGroup}}
2022-04-26 08:55:33 [43mdestination[0m > 2022-04-26 08:55:33 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(copyIntoTmpTableFromStage):122 - Uploading records from staging files to tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} (dataset tracking): [1.avro]
2022-04-26 08:55:33 [43mdestination[0m > 2022-04-26 08:55:33 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):126 - Uploading staged file: gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro
2022-04-26 08:55:33 [43mdestination[0m > 2022-04-26 08:55:33 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):135 - [JobId{project=data-stack-dev, job=43abe05a-2da7-4c97-94dd-6d0ebce2febc, location=europe-west1}] Created a new job to upload records to tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} (dataset tracking): Job{job=JobId{project=data-stack-dev, job=43abe05a-2da7-4c97-94dd-6d0ebce2febc, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963333579, endTime=null, startTime=1650963333686, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=+xA/HmtfltmNoU3nJRHTlQ==, generatedId=data-stack-dev:europe-west1.43abe05a-2da7-4c97-94dd-6d0ebce2febc, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/43abe05a-2da7-4c97-94dd-6d0ebce2febc?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}
2022-04-26 08:55:33 [43mdestination[0m > 2022-04-26 08:55:33 [32mINFO[m i.a.i.d.b.BigQueryUtils(waitForJobFinish):319 - Waiting for job finish Job{job=JobId{project=data-stack-dev, job=43abe05a-2da7-4c97-94dd-6d0ebce2febc, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963333579, endTime=null, startTime=1650963333686, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=+xA/HmtfltmNoU3nJRHTlQ==, generatedId=data-stack-dev:europe-west1.43abe05a-2da7-4c97-94dd-6d0ebce2febc, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/43abe05a-2da7-4c97-94dd-6d0ebce2febc?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-26 08:55:37 [43mdestination[0m > 2022-04-26 08:55:37 [32mINFO[m i.a.i.d.b.BigQueryUtils(waitForJobFinish):321 - Job finish Job{job=JobId{project=data-stack-dev, job=43abe05a-2da7-4c97-94dd-6d0ebce2febc, location=europe-west1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1650963333579, endTime=null, startTime=1650963333686, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte-mini-poc@data-stack-dev.iam.gserviceaccount.com, etag=+xA/HmtfltmNoU3nJRHTlQ==, generatedId=data-stack-dev:europe-west1.43abe05a-2da7-4c97-94dd-6d0ebce2febc, selfLink=https://www.googleapis.com/bigquery/v2/projects/data-stack-dev/jobs/43abe05a-2da7-4c97-94dd-6d0ebce2febc?location=europe-west1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, projectId=data-stack-dev, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=null, writeDisposition=WRITE_APPEND, formatOptions=FormatOptions{format=AVRO}, nullMarker=null, maxBadRecords=null, schema=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}]}, ignoreUnknownValue=null, sourceUris=[gs://mini-poc-staging/airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro], schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=true, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-26 08:55:37 [43mdestination[0m > 2022-04-26 08:55:37 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(lambda$copyIntoTmpTableFromStage$0):139 - [JobId{project=data-stack-dev, job=43abe05a-2da7-4c97-94dd-6d0ebce2febc, location=europe-west1}] Tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} (dataset tracking) is successfully appended with staging files
2022-04-26 08:55:37 [43mdestination[0m > 2022-04-26 08:55:37 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(copyIntoTargetTable):162 - Copying data from tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} to target table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalUser}} (dataset tracking, sync mode append)
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):185 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=sql2_tracking_LocalUser}}
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):156 - Finalizing tables in destination completed
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):159 - Cleaning up destination started for 2 streams
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_zmh_sql2_tracking_LocalGroup}} (dataset tracking)
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(dropStageIfExists):183 - Cleaning up staging path for stream sql2_tracking_LocalGroup (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalGroup
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.g.GcsStorageOperations(cleanUpObjects):41 - Deleting object airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.g.GcsStorageOperations(cleanUpObjects):41 - Deleting object airbyte/mini_poc/tracking_sql2_tracking_LocalGroup/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.s.S3StorageOperations(cleanUpBucketObject):253 - Storage bucket airbyte/mini_poc/tracking_sql2_tracking_LocalGroup has been cleaned-up (2 objects were deleted)...
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=tracking, tableId=_airbyte_tmp_ryt_sql2_tracking_LocalUser}} (dataset tracking)
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryGcsOperations(dropStageIfExists):183 - Cleaning up staging path for stream sql2_tracking_LocalUser (dataset tracking): airbyte/mini_poc/tracking_sql2_tracking_LocalUser
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.g.GcsStorageOperations(cleanUpObjects):41 - Deleting object airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.g.GcsStorageOperations(cleanUpObjects):41 - Deleting object airbyte/mini_poc/tracking_sql2_tracking_LocalUser/2022/04/26/08/c5a9ca7a-4f23-4be2-99c4-d5fb16b18247/1.avro
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.s.S3StorageOperations(cleanUpBucketObject):253 - Storage bucket airbyte/mini_poc/tracking_sql2_tracking_LocalUser has been cleaned-up (2 objects were deleted)...
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):164 - Cleaning up destination completed.
2022-04-26 08:55:39 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):349 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@3d32dfb0[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@33f53666[data={"cdc":false,"cdc_state":{"state":{"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n","mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650963257,\"file\":\"mysql-bin.001283\",\"pos\":1046594265,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"}}},"streams":[{"stream_name":"LocalGroup","stream_namespace":"tracking","cursor_field":[]},{"stream_name":"LocalUser","stream_namespace":"tracking","cursor_field":[]}]},additionalProperties={}],additionalProperties={}]
2022-04-26 08:55:39 [43mdestination[0m > 2022-04-26 08:55:39 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination
2022-04-26 08:55:40 [32mINFO[m i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-26 08:55:40 [32mINFO[m i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@305e24e4[status=completed,recordsSynced=6,bytesSynced=5262,startTime=1650963257938,endTime=1650963340079,totalStats=io.airbyte.config.SyncStats@7697d1dd[recordsEmitted=6,bytesEmitted=5262,stateMessagesEmitted=1,recordsCommitted=6],streamStats=[io.airbyte.config.StreamSyncStats@747dd1f0[streamName=sql2_tracking_LocalGroup,stats=io.airbyte.config.SyncStats@b0966db[recordsEmitted=3,bytesEmitted=3606,stateMessagesEmitted=<null>,recordsCommitted=3]], io.airbyte.config.StreamSyncStats@4ab10a5a[streamName=sql2_tracking_LocalUser,stats=io.airbyte.config.SyncStats@26023e8[recordsEmitted=3,bytesEmitted=1656,stateMessagesEmitted=<null>,recordsCommitted=3]]]]
2022-04-26 08:55:40 [32mINFO[m i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message
2022-04-26 08:55:40 [32mINFO[m i.a.w.DefaultReplicationWorker(run):254 - State capture: Updated state to: Optional[io.airbyte.config.State@18089005[state={"cdc":false,"cdc_state":{"state":{"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n","mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650963257,\"file\":\"mysql-bin.001283\",\"pos\":1046594265,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"}}},"streams":[{"stream_name":"LocalGroup","stream_namespace":"tracking","cursor_field":[]},{"stream_name":"LocalUser","stream_namespace":"tracking","cursor_field":[]}]}]]
2022-04-26 08:55:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-26 08:55:40 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@68ad9add[standardSyncSummary=io.airbyte.config.StandardSyncSummary@53eef87f[status=completed,recordsSynced=6,bytesSynced=5262,startTime=1650963257938,endTime=1650963340079,totalStats=io.airbyte.config.SyncStats@7697d1dd[recordsEmitted=6,bytesEmitted=5262,stateMessagesEmitted=1,recordsCommitted=6],streamStats=[io.airbyte.config.StreamSyncStats@747dd1f0[streamName=sql2_tracking_LocalGroup,stats=io.airbyte.config.SyncStats@b0966db[recordsEmitted=3,bytesEmitted=3606,stateMessagesEmitted=<null>,recordsCommitted=3]], io.airbyte.config.StreamSyncStats@4ab10a5a[streamName=sql2_tracking_LocalUser,stats=io.airbyte.config.SyncStats@26023e8[recordsEmitted=3,bytesEmitted=1656,stateMessagesEmitted=<null>,recordsCommitted=3]]]],normalizationSummary=<null>,state=io.airbyte.config.State@18089005[state={"cdc":false,"cdc_state":{"state":{"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n","mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650963257,\"file\":\"mysql-bin.001283\",\"pos\":1046594265,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"}}},"streams":[{"stream_name":"LocalGroup","stream_namespace":"tracking","cursor_field":[]},{"stream_name":"LocalUser","stream_namespace":"tracking","cursor_field":[]}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@353b503b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@7756f367[stream=io.airbyte.protocol.models.AirbyteStream@73a9f422[name=sql2_tracking_LocalGroup,jsonSchema={"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"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=tracking,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@57a0c728[stream=io.airbyte.protocol.models.AirbyteStream@3875ef6f[name=sql2_tracking_LocalUser,jsonSchema={"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"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=tracking,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-26 08:55:40 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-26 08:55:40 [32mINFO[m i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection f28955cc-927d-45dd-af4d-a49cff18fe55 state: io.airbyte.config.State@101f62f7[state={"cdc":false,"cdc_state":{"state":{"mysql_db_history":"{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"ddl\":\"SET character_set_server=latin1, collation_server=latin1_swedish_ci;\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`LocalUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentGroup`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP TABLE IF EXISTS `tracking`.`SegmentUser`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"DROP DATABASE IF EXISTS `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE DATABASE `tracking` CHARSET latin1 COLLATE latin1_swedish_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"USE `tracking`\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalGroup` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `LocalUser` (\\n  `id` varchar(100) COLLATE utf8_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentGroup` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `mrr` int(11) NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `commitmentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `userId` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `paymentRenew` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `country` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `companyName` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `membersCount` int(11) NOT NULL,\\n  `maxMembersCount` int(11) NOT NULL,\\n  `membersQuotaPercent` int(11) NOT NULL,\\n  `alertsCount` int(11) NOT NULL,\\n  `maxAlertsCount` int(11) NOT NULL,\\n  `alertsQuotaPercent` int(11) NOT NULL,\\n  `consumedQuota` int(11) NOT NULL,\\n  `consumedQuotaPercent` int(11) NOT NULL,\\n  `quota` int(11) NOT NULL,\\n  `booleanAccess` tinyint(1) NOT NULL,\\n  `plan` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `groupCreatedAt` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `isMnd` tinyint(1) NOT NULL,\\n  `reportsCount` int(11) NOT NULL,\\n  `maxReports` int(11) NOT NULL,\\n  `socialAccountCount` int(11) NOT NULL,\\n  `maxSocialAccount` int(11) NOT NULL,\\n  `apiAccess` tinyint(1) NOT NULL,\\n  `lastApiAccess` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `firstDateOfPayment` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `contractTotalAmount` int(11) NOT NULL,\\n  `paymentRecurrence` varchar(10) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChangeDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `lastMrrChange` int(11) NOT NULL,\\n  `totalPaidAmount` int(11) NOT NULL,\\n  `churnDate` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `churned` tinyint(1) NOT NULL,\\n  `timezone` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `fullCountryName` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `numberOfScheduledReports` int(11) NOT NULL,\\n  `daysBeforeQuotaRenew` int(11) NOT NULL,\\n  `lastQuotaConsumed` int(11) NOT NULL,\\n  `lastQuotaConsumedPercent` int(11) NOT NULL,\\n  `planCategory` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `paymentType` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  PRIMARY KEY (`id`)\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n{\"source\":{\"server\":\"tracking\"},\"position\":{\"file\":\"mysql-bin.001283\",\"pos\":1044225829,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405589189,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"snapshot\":true},\"databaseName\":\"tracking\",\"ddl\":\"CREATE TABLE `SegmentUser` (\\n  `id` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `status` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `group_id` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,\\n  `createdAt` datetime NOT NULL,\\n  `updatedAt` datetime NOT NULL,\\n  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `jobPosition` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `language` varchar(2) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '',\\n  `isVip` tinyint(1) NOT NULL DEFAULT '0',\\n  `bucket` smallint(6) NOT NULL DEFAULT '-1',\\n  `roleInGroup` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'undefined',\\n  `lastFullPushAt` datetime DEFAULT NULL,\\n  `isOwner` tinyint(1) NOT NULL,\\n  PRIMARY KEY (`id`),\\n  KEY `group_id` (`group_id`(191))\\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci\"}\n","mysql_cdc_offset":{"{\"schema\":null,\"payload\":[\"tracking\",{\"server\":\"tracking\"}]}":"{\"ts_sec\":1650963257,\"file\":\"mysql-bin.001283\",\"pos\":1046594265,\"gtids\":\"7fd08196-a72e-11e6-9505-0cc47a419f60:1-324,9c497e54-a682-11e6-90a4-0cc47a4166b4:1-2293417392,a9af7dc8-fb5f-11eb-94b0-d05099d23f90:1-405591415,e61e2c1e-ff71-11eb-af3c-d05099d38547:1-158224989\",\"row\":1,\"server_id\":1000000023,\"event\":2}"}}},"streams":[{"stream_name":"LocalGroup","stream_namespace":"tracking","cursor_field":[]},{"stream_name":"LocalUser","stream_namespace":"tracking","cursor_field":[]}]}]
2022-04-26 08:55:40 [32mINFO[m 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