2022-04-11 12:19:02 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.62-alpha 2022-04-11 12:19:02 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log 2022-04-11 12:19:02 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.62-alpha 2022-04-11 12:19:02 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 24 attempt id: 0 2022-04-11 12:19:02 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.pages=full_refresh - append, null.devices=full_refresh - append, null.daily_active_users=full_refresh - append, null.locations=full_refresh - append, null.monthly_active_users=full_refresh - append, null.weekly_active_users=full_refresh - append, null.two_weekly_active_users=full_refresh - append, null.four_weekly_active_users=full_refresh - append, null.traffic_sources=full_refresh - append, null.website_overview=full_refresh - append} 2022-04-11 12:19:02 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-11 12:19:02 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:1.0.1 exists... 2022-04-11 12:19:02 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery:1.0.1 was found locally. 2022-04-11 12:19:02 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 24 2022-04-11 12:19:02 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/24/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:1.0.1 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.62-alpha -e WORKER_JOB_ID=24 airbyte/destination-bigquery:1.0.1 write --config destination_config.json --catalog destination_catalog.json 2022-04-11 12:19:02 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-analytics-v4:0.1.16 exists... 2022-04-11 12:19:02 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-analytics-v4:0.1.16 was found locally. 2022-04-11 12:19:02 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 24 2022-04-11 12:19:02 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/24/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-google-analytics-v4:0.1.16 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.62-alpha -e WORKER_JOB_ID=24 airbyte/source-google-analytics-v4:0.1.16 read --config source_config.json --catalog source_catalog.json 2022-04-11 12:19:02 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-11 12:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-11 12:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-11 12:19:04 source > Starting syncing SourceGoogleAnalyticsV4 2022-04-11 12:19:05 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-11 12:19:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-11 12:19:05 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-11 12:19:05 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-11 12:19:05 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-11 12:19:06 destination > 2022-04-11 12:19:06 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-11 12:19:07 destination > 2022-04-11 12:19:07 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:08 destination > 2022-04-11 12:19:08 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_buw_daily_active_users}} created successfully 2022-04-11 12:19:08 destination > 2022-04-11 12:19:08 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:09 destination > 2022-04-11 12:19:09 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_hxy_devices}} created successfully 2022-04-11 12:19:09 destination > 2022-04-11 12:19:09 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:09 destination > 2022-04-11 12:19:09 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_imj_four_weekly_active_users}} created successfully 2022-04-11 12:19:09 destination > 2022-04-11 12:19:09 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:10 destination > 2022-04-11 12:19:10 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_kdh_locations}} created successfully 2022-04-11 12:19:10 destination > 2022-04-11 12:19:10 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:10 source > Syncing stream: daily_active_users 2022-04-11 12:19:10 destination > 2022-04-11 12:19:10 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_tfg_monthly_active_users}} created successfully 2022-04-11 12:19:11 destination > 2022-04-11 12:19:11 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:11 destination > 2022-04-11 12:19:11 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_ndj_pages}} created successfully 2022-04-11 12:19:11 destination > 2022-04-11 12:19:11 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:12 destination > 2022-04-11 12:19:12 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_zvc_traffic_sources}} created successfully 2022-04-11 12:19:12 destination > 2022-04-11 12:19:12 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:12 destination > 2022-04-11 12:19:12 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_hqv_two_weekly_active_users}} created successfully 2022-04-11 12:19:12 destination > 2022-04-11 12:19:12 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:13 destination > 2022-04-11 12:19:13 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_bxb_website_overview}} created successfully 2022-04-11 12:19:13 destination > 2022-04-11 12:19:13 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD 2022-04-11 12:19:13 destination > 2022-04-11 12:19:13 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_nyc_weekly_active_users}} created successfully 2022-04-11 12:22:45 source > Read 832 records from daily_active_users stream 2022-04-11 12:22:45 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:22:45 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:22:45 source > Syncing stream: devices 2022-04-11 12:23:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (115 KB) 2022-04-11 12:23:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (480 KB) 2022-04-11 12:23:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (827 KB) 2022-04-11 12:23:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (1 MB) 2022-04-11 12:23:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (1 MB) 2022-04-11 12:24:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (1 MB) 2022-04-11 12:24:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (2 MB) 2022-04-11 12:24:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (2 MB) 2022-04-11 12:24:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (2 MB) 2022-04-11 12:24:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (3 MB) 2022-04-11 12:25:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (3 MB) 2022-04-11 12:25:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (4 MB) 2022-04-11 12:25:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (4 MB) 2022-04-11 12:26:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (4 MB) 2022-04-11 12:26:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (5 MB) 2022-04-11 12:26:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 16000 (5 MB) 2022-04-11 12:26:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 17000 (5 MB) 2022-04-11 12:26:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 18000 (6 MB) 2022-04-11 12:27:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 19000 (6 MB) 2022-04-11 12:27:20 source > Read 19098 records from devices stream 2022-04-11 12:27:20 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:27:20 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:27:20 source > Syncing stream: four_weekly_active_users 2022-04-11 12:27:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 20000 (6 MB) 2022-04-11 12:29:46 source > Read 832 records from four_weekly_active_users stream 2022-04-11 12:29:46 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:29:46 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:29:46 source > Syncing stream: locations 2022-04-11 12:29:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 21000 (7 MB) 2022-04-11 12:29:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 22000 (7 MB) 2022-04-11 12:29:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 23000 (7 MB) 2022-04-11 12:29:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 24000 (8 MB) 2022-04-11 12:29:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 25000 (8 MB) 2022-04-11 12:29:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 26000 (9 MB) 2022-04-11 12:30:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 27000 (9 MB) 2022-04-11 12:30:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 28000 (9 MB) 2022-04-11 12:30:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 29000 (10 MB) 2022-04-11 12:30:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 30000 (10 MB) 2022-04-11 12:30:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 31000 (11 MB) 2022-04-11 12:30:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 32000 (11 MB) 2022-04-11 12:30:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 33000 (11 MB) 2022-04-11 12:30:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 34000 (12 MB) 2022-04-11 12:31:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 35000 (12 MB) 2022-04-11 12:31:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 36000 (13 MB) 2022-04-11 12:31:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 37000 (13 MB) 2022-04-11 12:31:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 38000 (13 MB) 2022-04-11 12:31:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 39000 (14 MB) 2022-04-11 12:31:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 40000 (14 MB) 2022-04-11 12:31:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 41000 (15 MB) 2022-04-11 12:31:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 42000 (15 MB) 2022-04-11 12:31:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 43000 (15 MB) 2022-04-11 12:31:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 44000 (16 MB) 2022-04-11 12:31:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 45000 (16 MB) 2022-04-11 12:31:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 46000 (17 MB) 2022-04-11 12:31:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 47000 (17 MB) 2022-04-11 12:31:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 48000 (17 MB) 2022-04-11 12:31:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 49000 (18 MB) 2022-04-11 12:31:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 50000 (18 MB) 2022-04-11 12:31:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 51000 (19 MB) 2022-04-11 12:31:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 52000 (19 MB) 2022-04-11 12:32:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 53000 (20 MB) 2022-04-11 12:32:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 54000 (20 MB) 2022-04-11 12:32:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 55000 (20 MB) 2022-04-11 12:32:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 56000 (21 MB) 2022-04-11 12:32:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 57000 (21 MB) 2022-04-11 12:32:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 58000 (22 MB) 2022-04-11 12:32:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 59000 (22 MB) 2022-04-11 12:32:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 60000 (22 MB) 2022-04-11 12:32:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 61000 (23 MB) 2022-04-11 12:32:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 62000 (23 MB) 2022-04-11 12:32:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 63000 (24 MB) 2022-04-11 12:32:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 64000 (24 MB) 2022-04-11 12:32:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 65000 (24 MB) 2022-04-11 12:33:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 66000 (25 MB) 2022-04-11 12:33:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 67000 (25 MB) 2022-04-11 12:33:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 68000 (26 MB) 2022-04-11 12:33:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 69000 (26 MB) 2022-04-11 12:33:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 70000 (27 MB) 2022-04-11 12:33:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 71000 (27 MB) 2022-04-11 12:33:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 72000 (27 MB) 2022-04-11 12:33:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 73000 (28 MB) 2022-04-11 12:33:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 74000 (28 MB) 2022-04-11 12:33:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 75000 (29 MB) 2022-04-11 12:33:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 76000 (29 MB) 2022-04-11 12:33:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 77000 (29 MB) 2022-04-11 12:33:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 78000 (30 MB) 2022-04-11 12:33:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 79000 (30 MB) 2022-04-11 12:33:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 80000 (31 MB) 2022-04-11 12:33:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 81000 (31 MB) 2022-04-11 12:33:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 82000 (31 MB) 2022-04-11 12:33:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 83000 (32 MB) 2022-04-11 12:33:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 84000 (32 MB) 2022-04-11 12:33:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 85000 (33 MB) 2022-04-11 12:33:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 86000 (33 MB) 2022-04-11 12:33:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 87000 (34 MB) 2022-04-11 12:33:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 88000 (34 MB) 2022-04-11 12:33:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 89000 (34 MB) 2022-04-11 12:33:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 90000 (35 MB) 2022-04-11 12:33:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 91000 (35 MB) 2022-04-11 12:34:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 92000 (36 MB) 2022-04-11 12:34:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 93000 (36 MB) 2022-04-11 12:34:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 94000 (36 MB) 2022-04-11 12:34:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 95000 (37 MB) 2022-04-11 12:34:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 96000 (37 MB) 2022-04-11 12:34:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 97000 (38 MB) 2022-04-11 12:34:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 98000 (38 MB) 2022-04-11 12:34:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 99000 (39 MB) 2022-04-11 12:34:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 100000 (39 MB) 2022-04-11 12:34:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 101000 (39 MB) 2022-04-11 12:34:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 102000 (40 MB) 2022-04-11 12:34:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 103000 (40 MB) 2022-04-11 12:34:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 104000 (41 MB) 2022-04-11 12:34:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 105000 (41 MB) 2022-04-11 12:34:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 106000 (41 MB) 2022-04-11 12:34:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 107000 (42 MB) 2022-04-11 12:34:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 108000 (42 MB) 2022-04-11 12:34:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 109000 (43 MB) 2022-04-11 12:34:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 110000 (43 MB) 2022-04-11 12:34:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 111000 (43 MB) 2022-04-11 12:34:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 112000 (44 MB) 2022-04-11 12:34:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 113000 (44 MB) 2022-04-11 12:34:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 114000 (45 MB) 2022-04-11 12:34:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 115000 (45 MB) 2022-04-11 12:34:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 116000 (46 MB) 2022-04-11 12:34:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 117000 (46 MB) 2022-04-11 12:34:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 118000 (46 MB) 2022-04-11 12:34:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 119000 (47 MB) 2022-04-11 12:34:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 120000 (47 MB) 2022-04-11 12:35:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 121000 (48 MB) 2022-04-11 12:35:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 122000 (48 MB) 2022-04-11 12:35:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 123000 (48 MB) 2022-04-11 12:35:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 124000 (49 MB) 2022-04-11 12:35:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 125000 (49 MB) 2022-04-11 12:35:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 126000 (50 MB) 2022-04-11 12:35:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 127000 (50 MB) 2022-04-11 12:35:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 128000 (51 MB) 2022-04-11 12:35:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 129000 (51 MB) 2022-04-11 12:35:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 130000 (51 MB) 2022-04-11 12:35:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 131000 (52 MB) 2022-04-11 12:35:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 132000 (52 MB) 2022-04-11 12:35:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 133000 (53 MB) 2022-04-11 12:35:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 134000 (53 MB) 2022-04-11 12:35:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 135000 (53 MB) 2022-04-11 12:35:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 136000 (54 MB) 2022-04-11 12:36:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 137000 (54 MB) 2022-04-11 12:36:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 138000 (55 MB) 2022-04-11 12:36:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 139000 (55 MB) 2022-04-11 12:36:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 140000 (55 MB) 2022-04-11 12:36:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 141000 (56 MB) 2022-04-11 12:36:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 142000 (56 MB) 2022-04-11 12:36:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 143000 (57 MB) 2022-04-11 12:36:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 144000 (57 MB) 2022-04-11 12:36:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 145000 (58 MB) 2022-04-11 12:36:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 146000 (58 MB) 2022-04-11 12:36:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 147000 (58 MB) 2022-04-11 12:36:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 148000 (59 MB) 2022-04-11 12:36:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 149000 (59 MB) 2022-04-11 12:36:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 150000 (60 MB) 2022-04-11 12:36:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 151000 (60 MB) 2022-04-11 12:36:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 152000 (60 MB) 2022-04-11 12:36:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 153000 (61 MB) 2022-04-11 12:36:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 154000 (61 MB) 2022-04-11 12:36:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 155000 (62 MB) 2022-04-11 12:36:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 156000 (62 MB) 2022-04-11 12:36:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 157000 (62 MB) 2022-04-11 12:36:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 158000 (63 MB) 2022-04-11 12:36:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 159000 (63 MB) 2022-04-11 12:36:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 160000 (64 MB) 2022-04-11 12:36:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 161000 (64 MB) 2022-04-11 12:36:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 162000 (65 MB) 2022-04-11 12:36:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 163000 (65 MB) 2022-04-11 12:37:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 164000 (65 MB) 2022-04-11 12:37:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 165000 (66 MB) 2022-04-11 12:37:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 166000 (66 MB) 2022-04-11 12:37:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 167000 (67 MB) 2022-04-11 12:37:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 168000 (67 MB) 2022-04-11 12:37:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 169000 (67 MB) 2022-04-11 12:37:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 170000 (68 MB) 2022-04-11 12:37:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 171000 (68 MB) 2022-04-11 12:37:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 172000 (69 MB) 2022-04-11 12:37:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 173000 (69 MB) 2022-04-11 12:37:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 174000 (69 MB) 2022-04-11 12:37:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 175000 (70 MB) 2022-04-11 12:37:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 176000 (70 MB) 2022-04-11 12:37:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 177000 (71 MB) 2022-04-11 12:37:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 178000 (71 MB) 2022-04-11 12:37:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 179000 (72 MB) 2022-04-11 12:37:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 180000 (72 MB) 2022-04-11 12:37:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 181000 (72 MB) 2022-04-11 12:37:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 182000 (73 MB) 2022-04-11 12:37:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 183000 (73 MB) 2022-04-11 12:37:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 184000 (74 MB) 2022-04-11 12:37:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 185000 (74 MB) 2022-04-11 12:37:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 186000 (74 MB) 2022-04-11 12:37:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 187000 (75 MB) 2022-04-11 12:37:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 188000 (75 MB) 2022-04-11 12:37:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 189000 (76 MB) 2022-04-11 12:38:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 190000 (76 MB) 2022-04-11 12:38:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 191000 (77 MB) 2022-04-11 12:38:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 192000 (77 MB) 2022-04-11 12:38:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 193000 (77 MB) 2022-04-11 12:38:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 194000 (78 MB) 2022-04-11 12:38:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 195000 (78 MB) 2022-04-11 12:38:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 196000 (79 MB) 2022-04-11 12:38:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 197000 (79 MB) 2022-04-11 12:38:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 198000 (79 MB) 2022-04-11 12:38:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 199000 (80 MB) 2022-04-11 12:38:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 200000 (80 MB) 2022-04-11 12:38:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 201000 (81 MB) 2022-04-11 12:38:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 202000 (81 MB) 2022-04-11 12:38:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 203000 (82 MB) 2022-04-11 12:38:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 204000 (82 MB) 2022-04-11 12:38:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 205000 (82 MB) 2022-04-11 12:38:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 206000 (83 MB) 2022-04-11 12:38:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 207000 (83 MB) 2022-04-11 12:38:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 208000 (84 MB) 2022-04-11 12:38:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 209000 (84 MB) 2022-04-11 12:38:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 210000 (84 MB) 2022-04-11 12:38:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 211000 (85 MB) 2022-04-11 12:38:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 212000 (85 MB) 2022-04-11 12:38:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 213000 (86 MB) 2022-04-11 12:38:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 214000 (86 MB) 2022-04-11 12:38:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 215000 (87 MB) 2022-04-11 12:38:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 216000 (87 MB) 2022-04-11 12:38:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 217000 (87 MB) 2022-04-11 12:38:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 218000 (88 MB) 2022-04-11 12:38:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 219000 (88 MB) 2022-04-11 12:38:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 220000 (89 MB) 2022-04-11 12:38:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 221000 (89 MB) 2022-04-11 12:38:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 222000 (89 MB) 2022-04-11 12:38:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 223000 (90 MB) 2022-04-11 12:38:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 224000 (90 MB) 2022-04-11 12:38:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 225000 (91 MB) 2022-04-11 12:38:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 226000 (91 MB) 2022-04-11 12:38:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 227000 (92 MB) 2022-04-11 12:38:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 228000 (92 MB) 2022-04-11 12:38:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 229000 (92 MB) 2022-04-11 12:38:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 230000 (93 MB) 2022-04-11 12:38:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 231000 (93 MB) 2022-04-11 12:38:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 232000 (94 MB) 2022-04-11 12:38:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 233000 (94 MB) 2022-04-11 12:39:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 234000 (94 MB) 2022-04-11 12:39:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 235000 (95 MB) 2022-04-11 12:39:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 236000 (95 MB) 2022-04-11 12:39:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 237000 (96 MB) 2022-04-11 12:39:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 238000 (96 MB) 2022-04-11 12:39:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 239000 (97 MB) 2022-04-11 12:39:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 240000 (97 MB) 2022-04-11 12:39:08 source > Read 219589 records from locations stream 2022-04-11 12:39:08 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:39:08 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:39:08 source > Syncing stream: monthly_active_users 2022-04-11 12:41:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 241000 (97 MB) 2022-04-11 12:42:35 source > Read 832 records from monthly_active_users stream 2022-04-11 12:42:35 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:42:35 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:42:35 source > Syncing stream: pages 2022-04-11 12:42:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 242000 (97 MB) 2022-04-11 12:42:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 243000 (98 MB) 2022-04-11 12:42:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 244000 (98 MB) 2022-04-11 12:42:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 245000 (99 MB) 2022-04-11 12:43:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 246000 (99 MB) 2022-04-11 12:43:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 247000 (99 MB) 2022-04-11 12:43:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 248000 (99 MB) 2022-04-11 12:43:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 249000 (100 MB) 2022-04-11 12:43:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 250000 (100 MB) 2022-04-11 12:43:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 251000 (100 MB) 2022-04-11 12:43:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 252000 (101 MB) 2022-04-11 12:43:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 253000 (101 MB) 2022-04-11 12:43:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 254000 (101 MB) 2022-04-11 12:43:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 255000 (102 MB) 2022-04-11 12:43:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 256000 (102 MB) 2022-04-11 12:44:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 257000 (102 MB) 2022-04-11 12:44:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 258000 (103 MB) 2022-04-11 12:44:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 259000 (103 MB) 2022-04-11 12:44:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 260000 (103 MB) 2022-04-11 12:44:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 261000 (103 MB) 2022-04-11 12:44:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 262000 (104 MB) 2022-04-11 12:44:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 263000 (104 MB) 2022-04-11 12:44:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 264000 (104 MB) 2022-04-11 12:44:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 265000 (105 MB) 2022-04-11 12:44:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 266000 (105 MB) 2022-04-11 12:44:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 267000 (105 MB) 2022-04-11 12:44:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 268000 (106 MB) 2022-04-11 12:44:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 269000 (106 MB) 2022-04-11 12:44:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 270000 (106 MB) 2022-04-11 12:44:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 271000 (107 MB) 2022-04-11 12:44:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 272000 (107 MB) 2022-04-11 12:44:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 273000 (108 MB) 2022-04-11 12:44:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 274000 (108 MB) 2022-04-11 12:44:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 275000 (108 MB) 2022-04-11 12:44:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 276000 (109 MB) 2022-04-11 12:45:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 277000 (109 MB) 2022-04-11 12:45:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 278000 (109 MB) 2022-04-11 12:45:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 279000 (110 MB) 2022-04-11 12:45:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 280000 (110 MB) 2022-04-11 12:45:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 281000 (110 MB) 2022-04-11 12:45:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 282000 (111 MB) 2022-04-11 12:45:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 283000 (111 MB) 2022-04-11 12:45:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 284000 (111 MB) 2022-04-11 12:45:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 285000 (112 MB) 2022-04-11 12:45:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 286000 (112 MB) 2022-04-11 12:45:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 287000 (113 MB) 2022-04-11 12:45:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 288000 (113 MB) 2022-04-11 12:45:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 289000 (113 MB) 2022-04-11 12:45:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 290000 (114 MB) 2022-04-11 12:45:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 291000 (114 MB) 2022-04-11 12:45:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 292000 (114 MB) 2022-04-11 12:45:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 293000 (115 MB) 2022-04-11 12:45:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 294000 (115 MB) 2022-04-11 12:45:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 295000 (115 MB) 2022-04-11 12:45:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 296000 (116 MB) 2022-04-11 12:45:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 297000 (116 MB) 2022-04-11 12:45:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 298000 (116 MB) 2022-04-11 12:45:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 299000 (117 MB) 2022-04-11 12:45:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 300000 (117 MB) 2022-04-11 12:45:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 301000 (117 MB) 2022-04-11 12:45:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 302000 (118 MB) 2022-04-11 12:45:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 303000 (118 MB) 2022-04-11 12:45:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 304000 (119 MB) 2022-04-11 12:45:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 305000 (119 MB) 2022-04-11 12:45:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 306000 (119 MB) 2022-04-11 12:45:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 307000 (120 MB) 2022-04-11 12:45:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 308000 (120 MB) 2022-04-11 12:46:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 309000 (120 MB) 2022-04-11 12:46:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 310000 (121 MB) 2022-04-11 12:46:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 311000 (121 MB) 2022-04-11 12:46:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 312000 (121 MB) 2022-04-11 12:46:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 313000 (122 MB) 2022-04-11 12:46:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 314000 (122 MB) 2022-04-11 12:46:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 315000 (122 MB) 2022-04-11 12:46:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 316000 (123 MB) 2022-04-11 12:46:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 317000 (123 MB) 2022-04-11 12:46:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 318000 (123 MB) 2022-04-11 12:46:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 319000 (124 MB) 2022-04-11 12:46:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 320000 (124 MB) 2022-04-11 12:46:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 321000 (124 MB) 2022-04-11 12:46:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 322000 (125 MB) 2022-04-11 12:46:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 323000 (125 MB) 2022-04-11 12:46:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 324000 (125 MB) 2022-04-11 12:46:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 325000 (126 MB) 2022-04-11 12:46:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 326000 (126 MB) 2022-04-11 12:46:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 327000 (127 MB) 2022-04-11 12:46:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 328000 (127 MB) 2022-04-11 12:46:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 329000 (127 MB) 2022-04-11 12:46:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 330000 (128 MB) 2022-04-11 12:46:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 331000 (128 MB) 2022-04-11 12:46:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 332000 (128 MB) 2022-04-11 12:46:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 333000 (129 MB) 2022-04-11 12:46:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 334000 (129 MB) 2022-04-11 12:46:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 335000 (129 MB) 2022-04-11 12:46:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 336000 (130 MB) 2022-04-11 12:46:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 337000 (130 MB) 2022-04-11 12:46:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 338000 (130 MB) 2022-04-11 12:46:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 339000 (131 MB) 2022-04-11 12:46:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 340000 (131 MB) 2022-04-11 12:46:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 341000 (131 MB) 2022-04-11 12:46:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 342000 (132 MB) 2022-04-11 12:46:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 343000 (132 MB) 2022-04-11 12:46:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 344000 (133 MB) 2022-04-11 12:46:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 345000 (133 MB) 2022-04-11 12:46:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 346000 (133 MB) 2022-04-11 12:46:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 347000 (134 MB) 2022-04-11 12:46:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 348000 (134 MB) 2022-04-11 12:46:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 349000 (134 MB) 2022-04-11 12:46:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 350000 (135 MB) 2022-04-11 12:46:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 351000 (135 MB) 2022-04-11 12:46:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 352000 (135 MB) 2022-04-11 12:46:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 353000 (136 MB) 2022-04-11 12:46:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 354000 (136 MB) 2022-04-11 12:47:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 355000 (136 MB) 2022-04-11 12:47:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 356000 (137 MB) 2022-04-11 12:47:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 357000 (137 MB) 2022-04-11 12:47:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 358000 (138 MB) 2022-04-11 12:47:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 359000 (138 MB) 2022-04-11 12:47:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 360000 (138 MB) 2022-04-11 12:47:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 361000 (139 MB) 2022-04-11 12:47:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 362000 (139 MB) 2022-04-11 12:47:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 363000 (139 MB) 2022-04-11 12:47:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 364000 (140 MB) 2022-04-11 12:47:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 365000 (140 MB) 2022-04-11 12:47:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 366000 (140 MB) 2022-04-11 12:47:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 367000 (141 MB) 2022-04-11 12:47:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 368000 (141 MB) 2022-04-11 12:47:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 369000 (141 MB) 2022-04-11 12:47:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 370000 (142 MB) 2022-04-11 12:47:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 371000 (142 MB) 2022-04-11 12:47:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 372000 (142 MB) 2022-04-11 12:47:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 373000 (143 MB) 2022-04-11 12:47:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 374000 (143 MB) 2022-04-11 12:47:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 375000 (144 MB) 2022-04-11 12:47:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 376000 (144 MB) 2022-04-11 12:47:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 377000 (144 MB) 2022-04-11 12:47:26 source > Read 136655 records from pages stream 2022-04-11 12:47:26 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:47:26 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:47:26 source > Syncing stream: traffic_sources 2022-04-11 12:47:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 378000 (145 MB) 2022-04-11 12:47:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 379000 (145 MB) 2022-04-11 12:48:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 380000 (145 MB) 2022-04-11 12:48:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 381000 (146 MB) 2022-04-11 12:48:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 382000 (146 MB) 2022-04-11 12:48:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 383000 (146 MB) 2022-04-11 12:48:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 384000 (147 MB) 2022-04-11 12:48:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 385000 (147 MB) 2022-04-11 12:49:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 386000 (147 MB) 2022-04-11 12:49:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 387000 (148 MB) 2022-04-11 12:49:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 388000 (148 MB) 2022-04-11 12:49:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 389000 (148 MB) 2022-04-11 12:49:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 390000 (149 MB) 2022-04-11 12:49:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 391000 (149 MB) 2022-04-11 12:49:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 392000 (150 MB) 2022-04-11 12:50:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 393000 (150 MB) 2022-04-11 12:50:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 394000 (150 MB) 2022-04-11 12:50:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 395000 (151 MB) 2022-04-11 12:50:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 396000 (151 MB) 2022-04-11 12:50:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 397000 (151 MB) 2022-04-11 12:50:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 398000 (152 MB) 2022-04-11 12:50:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 399000 (152 MB) 2022-04-11 12:50:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 400000 (152 MB) 2022-04-11 12:51:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 401000 (153 MB) 2022-04-11 12:51:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 402000 (153 MB) 2022-04-11 12:51:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 403000 (153 MB) 2022-04-11 12:51:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 404000 (154 MB) 2022-04-11 12:51:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 405000 (154 MB) 2022-04-11 12:51:29 source > Read 27422 records from traffic_sources stream 2022-04-11 12:51:29 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:51:29 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:51:29 source > Syncing stream: two_weekly_active_users 2022-04-11 12:53:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 406000 (154 MB) 2022-04-11 12:53:55 source > Read 832 records from two_weekly_active_users stream 2022-04-11 12:53:55 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:53:55 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:53:55 source > Syncing stream: website_overview 2022-04-11 12:56:50 source > Read 832 records from website_overview stream 2022-04-11 12:56:50 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:56:50 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:56:50 source > Syncing stream: weekly_active_users 2022-04-11 12:57:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 407000 (155 MB) 2022-04-11 12:59:36 source > Read 832 records from weekly_active_users stream 2022-04-11 12:59:36 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:59:36 source > SourceGoogleAnalyticsV4 runtimes: 2022-04-11 12:59:36 source > Finished syncing SourceGoogleAnalyticsV4 2022-04-11 12:59:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 407756 (155 MB) 2022-04-11 12:59:37 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-04-11 12:59:37 destination > 2022-04-11 12:59:37 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-04-11 12:59:37 destination > 2022-04-11 12:59:37 INFO i.a.i.d.b.BigQueryRecordConsumer(close):58 - Started closing all connections 2022-04-11 12:59:37 destination > 2022-04-11 12:59:37 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 12:59:37 destination > 2022-04-11 12:59:37 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 12:59:37 destination > 2022-04-11 12:59:37 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_two_weekly_active_users, tmpTable=_airbyte_tmp_hqv_two_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:39 destination > 2022-04-11 12:59:39 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_hqv_two_weekly_active_users to the source table _airbyte_raw_two_weekly_active_users. 2022-04-11 12:59:39 destination > 2022-04-11 12:59:39 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_hqv_two_weekly_active_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_two_weekly_active_users}} 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_two_weekly_active_users! 2022-04-11 12:59:44 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 12:59:44 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_two_weekly_active_users, tmpTable=_airbyte_tmp_hqv_two_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 12:59:44 destination > 2022-04-11 12:59:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_four_weekly_active_users, tmpTable=_airbyte_tmp_imj_four_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:46 destination > 2022-04-11 12:59:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_imj_four_weekly_active_users to the source table _airbyte_raw_four_weekly_active_users. 2022-04-11 12:59:46 destination > 2022-04-11 12:59:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_imj_four_weekly_active_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_four_weekly_active_users}} 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_four_weekly_active_users! 2022-04-11 12:59:49 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 12:59:49 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_four_weekly_active_users, tmpTable=_airbyte_tmp_imj_four_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 12:59:49 destination > 2022-04-11 12:59:49 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_weekly_active_users, tmpTable=_airbyte_tmp_nyc_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:55 destination > 2022-04-11 12:59:55 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_nyc_weekly_active_users to the source table _airbyte_raw_weekly_active_users. 2022-04-11 12:59:55 destination > 2022-04-11 12:59:55 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_nyc_weekly_active_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_weekly_active_users}} 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_weekly_active_users! 2022-04-11 12:59:58 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 12:59:58 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_weekly_active_users, tmpTable=_airbyte_tmp_nyc_weekly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 12:59:58 destination > 2022-04-11 12:59:58 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_monthly_active_users, tmpTable=_airbyte_tmp_tfg_monthly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:01 destination > 2022-04-11 13:00:01 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_tfg_monthly_active_users to the source table _airbyte_raw_monthly_active_users. 2022-04-11 13:00:01 destination > 2022-04-11 13:00:01 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_tfg_monthly_active_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_monthly_active_users}} 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_monthly_active_users! 2022-04-11 13:00:05 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:05 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_monthly_active_users, tmpTable=_airbyte_tmp_tfg_monthly_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:05 destination > 2022-04-11 13:00:05 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_website_overview, tmpTable=_airbyte_tmp_bxb_website_overview, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:09 destination > 2022-04-11 13:00:09 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_bxb_website_overview to the source table _airbyte_raw_website_overview. 2022-04-11 13:00:09 destination > 2022-04-11 13:00:09 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_bxb_website_overview}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_website_overview}} 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_website_overview! 2022-04-11 13:00:12 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:12 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_website_overview, tmpTable=_airbyte_tmp_bxb_website_overview, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:12 destination > 2022-04-11 13:00:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_daily_active_users, tmpTable=_airbyte_tmp_buw_daily_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:14 destination > 2022-04-11 13:00:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_buw_daily_active_users to the source table _airbyte_raw_daily_active_users. 2022-04-11 13:00:14 destination > 2022-04-11 13:00:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_buw_daily_active_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_daily_active_users}} 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_daily_active_users! 2022-04-11 13:00:16 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:16 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_daily_active_users, tmpTable=_airbyte_tmp_buw_daily_active_users, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:16 destination > 2022-04-11 13:00:16 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_devices, tmpTable=_airbyte_tmp_hxy_devices, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:19 destination > 2022-04-11 13:00:19 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_hxy_devices to the source table _airbyte_raw_devices. 2022-04-11 13:00:19 destination > 2022-04-11 13:00:19 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_hxy_devices}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_devices}} 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_devices! 2022-04-11 13:00:21 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:21 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_devices, tmpTable=_airbyte_tmp_hxy_devices, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:21 destination > 2022-04-11 13:00:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_pages, tmpTable=_airbyte_tmp_ndj_pages, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:27 destination > 2022-04-11 13:00:27 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_ndj_pages to the source table _airbyte_raw_pages. 2022-04-11 13:00:27 destination > 2022-04-11 13:00:27 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_ndj_pages}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_pages}} 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_pages! 2022-04-11 13:00:29 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:29 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_pages, tmpTable=_airbyte_tmp_ndj_pages, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:29 destination > 2022-04-11 13:00:29 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_locations, tmpTable=_airbyte_tmp_kdh_locations, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:38 destination > 2022-04-11 13:00:38 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_kdh_locations to the source table _airbyte_raw_locations. 2022-04-11 13:00:38 destination > 2022-04-11 13:00:38 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_kdh_locations}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_locations}} 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_locations! 2022-04-11 13:00:40 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:40 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_locations, tmpTable=_airbyte_tmp_kdh_locations, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format. 2022-04-11 13:00:40 destination > 2022-04-11 13:00:40 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_traffic_sources, tmpTable=_airbyte_tmp_zvc_traffic_sources, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:44 destination > 2022-04-11 13:00:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_zvc_traffic_sources to the source table _airbyte_raw_traffic_sources. 2022-04-11 13:00:44 destination > 2022-04-11 13:00:44 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_tmp_zvc_traffic_sources}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=google_analytics_raw_data, tableId=_airbyte_raw_traffic_sources}} 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_traffic_sources! 2022-04-11 13:00:46 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-11 13:00:46 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted. 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables... 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_traffic_sources, tmpTable=_airbyte_tmp_zvc_traffic_sources, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-04-11 13:00:46 destination > 2022-04-11 13:00:46 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-04-11 13:00:46 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete. 2022-04-11 13:00:46 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@54d1ce9d[status=completed,recordsSynced=407756,bytesSynced=162604535,startTime=1649679542310,endTime=1649682046725,totalStats=io.airbyte.config.SyncStats@510ef006[recordsEmitted=407756,bytesEmitted=162604535,stateMessagesEmitted=0,recordsCommitted=407756],streamStats=[io.airbyte.config.StreamSyncStats@76628c9c[streamName=monthly_active_users,stats=io.airbyte.config.SyncStats@e659c43[recordsEmitted=832,bytesEmitted=56518,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@541a1e34[streamName=weekly_active_users,stats=io.airbyte.config.SyncStats@72b24a71[recordsEmitted=832,bytesEmitted=55223,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@10563ed7[streamName=pages,stats=io.airbyte.config.SyncStats@32f33f1a[recordsEmitted=136655,bytesEmitted=49702718,stateMessagesEmitted=,recordsCommitted=136655]], io.airbyte.config.StreamSyncStats@361c6cce[streamName=devices,stats=io.airbyte.config.SyncStats@569d49be[recordsEmitted=19098,bytesEmitted=7233873,stateMessagesEmitted=,recordsCommitted=19098]], io.airbyte.config.StreamSyncStats@779c653c[streamName=traffic_sources,stats=io.airbyte.config.SyncStats@5c3c9f3a[recordsEmitted=27422,bytesEmitted=10094917,stateMessagesEmitted=,recordsCommitted=27422]], io.airbyte.config.StreamSyncStats@993f26f[streamName=two_weekly_active_users,stats=io.airbyte.config.SyncStats@35ff8a5a[recordsEmitted=832,bytesEmitted=56284,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@215ebc5c[streamName=locations,stats=io.airbyte.config.SyncStats@19233202[recordsEmitted=219589,bytesEmitted=95006321,stateMessagesEmitted=,recordsCommitted=219589]], io.airbyte.config.StreamSyncStats@f35abc3[streamName=website_overview,stats=io.airbyte.config.SyncStats@46514d25[recordsEmitted=832,bytesEmitted=287666,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@1239a5ef[streamName=daily_active_users,stats=io.airbyte.config.SyncStats@120a2688[recordsEmitted=832,bytesEmitted=54510,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@3043fcb9[streamName=four_weekly_active_users,stats=io.airbyte.config.SyncStats@7cb7a7f1[recordsEmitted=832,bytesEmitted=56505,stateMessagesEmitted=,recordsCommitted=832]]]] 2022-04-11 13:00:46 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-11 13:00:46 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained. 2022-04-11 13:00:46 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-11 13:00:46 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@2c95894b[standardSyncSummary=io.airbyte.config.StandardSyncSummary@a17bfad[status=completed,recordsSynced=407756,bytesSynced=162604535,startTime=1649679542310,endTime=1649682046725,totalStats=io.airbyte.config.SyncStats@510ef006[recordsEmitted=407756,bytesEmitted=162604535,stateMessagesEmitted=0,recordsCommitted=407756],streamStats=[io.airbyte.config.StreamSyncStats@76628c9c[streamName=monthly_active_users,stats=io.airbyte.config.SyncStats@e659c43[recordsEmitted=832,bytesEmitted=56518,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@541a1e34[streamName=weekly_active_users,stats=io.airbyte.config.SyncStats@72b24a71[recordsEmitted=832,bytesEmitted=55223,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@10563ed7[streamName=pages,stats=io.airbyte.config.SyncStats@32f33f1a[recordsEmitted=136655,bytesEmitted=49702718,stateMessagesEmitted=,recordsCommitted=136655]], io.airbyte.config.StreamSyncStats@361c6cce[streamName=devices,stats=io.airbyte.config.SyncStats@569d49be[recordsEmitted=19098,bytesEmitted=7233873,stateMessagesEmitted=,recordsCommitted=19098]], io.airbyte.config.StreamSyncStats@779c653c[streamName=traffic_sources,stats=io.airbyte.config.SyncStats@5c3c9f3a[recordsEmitted=27422,bytesEmitted=10094917,stateMessagesEmitted=,recordsCommitted=27422]], io.airbyte.config.StreamSyncStats@993f26f[streamName=two_weekly_active_users,stats=io.airbyte.config.SyncStats@35ff8a5a[recordsEmitted=832,bytesEmitted=56284,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@215ebc5c[streamName=locations,stats=io.airbyte.config.SyncStats@19233202[recordsEmitted=219589,bytesEmitted=95006321,stateMessagesEmitted=,recordsCommitted=219589]], io.airbyte.config.StreamSyncStats@f35abc3[streamName=website_overview,stats=io.airbyte.config.SyncStats@46514d25[recordsEmitted=832,bytesEmitted=287666,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@1239a5ef[streamName=daily_active_users,stats=io.airbyte.config.SyncStats@120a2688[recordsEmitted=832,bytesEmitted=54510,stateMessagesEmitted=,recordsCommitted=832]], io.airbyte.config.StreamSyncStats@3043fcb9[streamName=four_weekly_active_users,stats=io.airbyte.config.SyncStats@7cb7a7f1[recordsEmitted=832,bytesEmitted=56505,stateMessagesEmitted=,recordsCommitted=832]]]],state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@548eed9b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5bc97a97[stream=io.airbyte.protocol.models.AirbyteStream@5b967f74[name=daily_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_1dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6ccb597c[stream=io.airbyte.protocol.models.AirbyteStream@4f8a834b[name=devices,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_browser":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_deviceCategory":{"type":["string"]},"ga_operatingSystem":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5f8745ef[stream=io.airbyte.protocol.models.AirbyteStream@3782ecb4[name=four_weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_28dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1b44381[stream=io.airbyte.protocol.models.AirbyteStream@1abf1827[name=locations,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_city":{"type":["string"]},"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_metro":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_region":{"type":["string"]},"ga_country":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_continent":{"type":["string"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_subContinent":{"type":["string"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7ff28ea2[stream=io.airbyte.protocol.models.AirbyteStream@5fb53aa4[name=monthly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_30dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7c3ed298[stream=io.airbyte.protocol.models.AirbyteStream@1ea28318[name=pages,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_exits":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_hostname":{"type":["string"]},"ga_pagePath":{"type":["string"]},"ga_entrances":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_entranceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_uniquePageviews":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@754e89f0[stream=io.airbyte.protocol.models.AirbyteStream@3d8ede7[name=traffic_sources,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_medium":{"type":["string"]},"ga_source":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_socialNetwork":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@9f85516[stream=io.airbyte.protocol.models.AirbyteStream@3c8bd72[name=two_weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_14dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@248b5f2[stream=io.airbyte.protocol.models.AirbyteStream@463bc789[name=website_overview,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@d207abd[stream=io.airbyte.protocol.models.AirbyteStream@4b457546[name=weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_7dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=google_analytics_raw_data,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-04-11 13:00:46 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-11 13:00:46 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log 2022-04-11 13:00:46 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.62-alpha 2022-04-11 13:00:46 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-04-11 13:00:46 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.74 2022-04-11 13:00:46 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.74 exists... 2022-04-11 13:00:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.74 was found locally. 2022-04-11 13:00:46 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 24 2022-04-11 13:00:46 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/24/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.62-alpha airbyte/normalization:0.1.74 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json 2022-04-11 13:00:47 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/24/0/normalize 2022-04-11 13:00:47 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/24/0/normalize') 2022-04-11 13:00:47 normalization > transform_bigquery 2022-04-11 13:00:47 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/24/0/normalize --catalog destination_catalog.json --out /data/24/0/normalize/models/generated/ --json-column _airbyte_data 2022-04-11 13:00:47 normalization > Processing destination_catalog.json... 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/daily_active_users_ab1.sql from daily_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/daily_active_users_ab2.sql from daily_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/daily_active_users_ab3.sql from daily_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/daily_active_users.sql from daily_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/devices_ab1.sql from devices 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/devices_ab2.sql from devices 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/devices_ab3.sql from devices 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/devices.sql from devices 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/four_weekly_active_users_ab1.sql from four_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/four_weekly_active_users_ab2.sql from four_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/four_weekly_active_users_ab3.sql from four_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/four_weekly_active_users.sql from four_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/locations_ab1.sql from locations 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/locations_ab2.sql from locations 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/locations_ab3.sql from locations 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/locations.sql from locations 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/monthly_active_users_ab1.sql from monthly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/monthly_active_users_ab2.sql from monthly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/monthly_active_users_ab3.sql from monthly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/monthly_active_users.sql from monthly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/pages_ab1.sql from pages 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/pages_ab2.sql from pages 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/pages_ab3.sql from pages 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/pages.sql from pages 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/traffic_sources_ab1.sql from traffic_sources 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/traffic_sources_ab2.sql from traffic_sources 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/traffic_sources_ab3.sql from traffic_sources 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/traffic_sources.sql from traffic_sources 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/two_weekly_active_users_ab1.sql from two_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/two_weekly_active_users_ab2.sql from two_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/two_weekly_active_users_ab3.sql from two_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/two_weekly_active_users.sql from two_weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/website_overview_ab1.sql from website_overview 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/website_overview_ab2.sql from website_overview 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/website_overview_ab3.sql from website_overview 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/website_overview.sql from website_overview 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/weekly_active_users_ab1.sql from weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/weekly_active_users_ab2.sql from weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_ctes/google_analytics_raw_data/weekly_active_users_ab3.sql from weekly_active_users 2022-04-11 13:00:47 normalization > Generating airbyte_incremental/google_analytics_raw_data/weekly_active_users.sql from weekly_active_users 2022-04-11 13:00:48 normalization > detected no config file for ssh, assuming ssh is off. 2022-04-11 13:00:51 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-04-11 13:00:51 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-04-11 13:00:51 normalization > 2022-04-11 13:00:51 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-04-11 13:00:51 normalization > 2022-04-11 13:00:55 normalization > 13:00:55 Running with dbt=1.0.0 2022-04-11 13:00:55 normalization > 13:00:55 Partial parse save file not found. Starting full parse. 2022-04-11 13:00:57 normalization > 13:00:57 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-11 13:00:57 normalization > There are 2 unused configuration paths: 2022-04-11 13:00:57 normalization > - models.airbyte_utils.generated.airbyte_views 2022-04-11 13:00:57 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-04-11 13:00:57 normalization > 2022-04-11 13:00:57 normalization > 13:00:57 Found 40 models, 0 tests, 0 snapshots, 0 analyses, 537 macros, 0 operations, 0 seed files, 10 sources, 0 exposures, 0 metrics 2022-04-11 13:00:57 normalization > 13:00:57 2022-04-11 13:00:58 normalization > 13:00:58 Concurrency: 8 threads (target='prod') 2022-04-11 13:00:58 normalization > 13:00:58 2022-04-11 13:01:00 normalization > 13:00:59 1 of 10 START incremental model google_analytics_raw_data.devices....................................................... [RUN] 2022-04-11 13:01:00 normalization > 13:00:59 2 of 10 START incremental model google_analytics_raw_data.pages......................................................... [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 3 of 10 START incremental model google_analytics_raw_data.traffic_sources............................................... [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 4 of 10 START incremental model google_analytics_raw_data.daily_active_users............................................ [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 5 of 10 START incremental model google_analytics_raw_data.four_weekly_active_users...................................... [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 6 of 10 START incremental model google_analytics_raw_data.two_weekly_active_users....................................... [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 7 of 10 START incremental model google_analytics_raw_data.weekly_active_users........................................... [RUN] 2022-04-11 13:01:00 normalization > 13:01:00 8 of 10 START incremental model google_analytics_raw_data.website_overview.............................................. [RUN] 2022-04-11 13:01:06 normalization > 13:01:06 7 of 10 OK created incremental model google_analytics_raw_data.weekly_active_users...................................... [MERGE (833.0 rows, 205.1 KB processed) in 5.37s] 2022-04-11 13:01:06 normalization > 13:01:06 9 of 10 START incremental model google_analytics_raw_data.locations..................................................... [RUN] 2022-04-11 13:01:06 normalization > 13:01:06 5 of 10 OK created incremental model google_analytics_raw_data.four_weekly_active_users................................. [MERGE (833.0 rows, 216.8 KB processed) in 5.68s] 2022-04-11 13:01:06 normalization > 13:01:06 10 of 10 START incremental model google_analytics_raw_data.monthly_active_users......................................... [RUN] 2022-04-11 13:01:06 normalization > 13:01:06 4 of 10 OK created incremental model google_analytics_raw_data.daily_active_users....................................... [MERGE (833.0 rows, 216.8 KB processed) in 5.93s] 2022-04-11 13:01:06 normalization > 13:01:06 6 of 10 OK created incremental model google_analytics_raw_data.two_weekly_active_users.................................. [MERGE (833.0 rows, 216.8 KB processed) in 5.95s] 2022-04-11 13:01:06 normalization > 13:01:06 8 of 10 OK created incremental model google_analytics_raw_data.website_overview......................................... [MERGE (833.0 rows, 275.4 KB processed) in 6.26s] 2022-04-11 13:01:07 normalization > 13:01:07 1 of 10 OK created incremental model google_analytics_raw_data.devices.................................................. [MERGE (19.1k rows, 6.7 MB processed) in 7.44s] 2022-04-11 13:01:07 normalization > 13:01:07 3 of 10 OK created incremental model google_analytics_raw_data.traffic_sources.......................................... [MERGE (27.4k rows, 8.8 MB processed) in 7.93s] 2022-04-11 13:01:11 normalization > 13:01:11 10 of 10 OK created incremental model google_analytics_raw_data.monthly_active_users.................................... [MERGE (833.0 rows, 216.8 KB processed) in 4.95s] 2022-04-11 13:01:15 normalization > 13:01:15 2 of 10 OK created incremental model google_analytics_raw_data.pages.................................................... [MERGE (136.7k rows, 57.6 MB processed) in 15.53s] 2022-04-11 13:01:32 normalization > 13:01:32 9 of 10 OK created incremental model google_analytics_raw_data.locations................................................ [MERGE (219.6k rows, 86.7 MB processed) in 26.95s] 2022-04-11 13:01:32 normalization > 13:01:32 2022-04-11 13:01:32 normalization > 13:01:32 Finished running 10 incremental models in 35.32s. 2022-04-11 13:01:33 normalization > 13:01:33 2022-04-11 13:01:33 normalization > 13:01:33 Completed successfully 2022-04-11 13:01:33 normalization > 13:01:33 2022-04-11 13:01:33 normalization > 13:01:33 Done. PASS=10 WARN=0 ERROR=0 SKIP=0 TOTAL=10 2022-04-11 13:01:33 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 46 seconds. 2022-04-11 13:01:33 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-11 13:01:33 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-11 13:01:33 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.client_id: is missing but it is required, $.client_secret: is missing but it is required, $.refresh_token: is missing but it is required, $.auth_type: must be a constant value Client, $.auth_type: does not have a value in the enumeration [Client]