Missing values in HubSpot tickets object #8055

ghost · 2021-11-17T14:39:43Z

Environment

Airbyte version: 0.30.34-alpha
OS Version / Instance: GCP e2-standard-2
Deployment: Docker
Source Connector and version: Hubspot 0.1.24 (latest)
Destination Connector and version: BigQuery 0.5.0 (latest)
Severity: Low
Step where error happened: Sync job

Current Behavior

Whenever retrieving the ticket and ticket_properties objects from HubSpot some fields (hs_time_in_XXX) are always null even if the same fields retrieved using HubSpot API have correct and relevant values.

Expected Behavior

I would expect the applicable fields hs_time_in_XXX to have the same value returned by the API call.

Logs

LOG


2021-11-16 13:42:20 INFO () WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2021-11-16 13:42:21 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2021-11-16 13:42:21 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2021-11-16 13:42:21 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2021-11-16 13:42:21 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2021-11-16 13:42:21 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 74 attempt id: 0
2021-11-16 13:42:21 INFO () DefaultReplicationWorker(run):91 - configured sync modes: {null.tickets=full_refresh - overwrite, null.engagements=full_refresh - overwrite, null.owners=full_refresh - overwrite}
2021-11-16 13:42:21 INFO () DefaultAirbyteDestination(start):64 - Running destination...
2021-11-16 13:42:21 INFO () LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:0.5.0 exists...
2021-11-16 13:42:21 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/74/0 --network host --log-driver none airbyte/destination-bigquery:0.5.0 write --config destination_config.json --catalog destination_catalog.json
2021-11-16 13:42:21 INFO () LineGobbler(voidCall):82 - airbyte/destination-bigquery:0.5.0 was found locally.
2021-11-16 13:42:21 INFO () LineGobbler(voidCall):82 - Checking if airbyte/source-hubspot:0.1.24 exists...
2021-11-16 13:42:21 INFO () LineGobbler(voidCall):82 - airbyte/source-hubspot:0.1.24 was found locally.
2021-11-16 13:42:21 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/74/0 --network host --log-driver none airbyte/source-hubspot:0.1.24 read --config source_config.json --catalog source_catalog.json --state input_state.json
2021-11-16 13:42:21 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started.
2021-11-16 13:42:21 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join.
2021-11-16 13:42:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started.
�[35mdestination�[0m - 2021-11-16 13:42:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:24 �[32mINFO�[m i.a.i.d.b.BigQueryDestination(main):334 - {} - starting destination: class io.airbyte.integrations.destination.bigquery.BigQueryDestination
�[35mdestination�[0m - 2021-11-16 13:42:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:24 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
�[35mdestination�[0m - 2021-11-16 13:42:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:24 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):115 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
�[35mdestination�[0m - 2021-11-16 13:42:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:24 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE
�[35mdestination�[0m - 2021-11-16 13:42:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:24 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):81 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
�[35mdestination�[0m - 2021-11-16 13:42:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:25 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
�[35mdestination�[0m - 2021-11-16 13:42:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:25 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
�[35mdestination�[0m - 2021-11-16 13:42:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:25 �[32mINFO�[m i.a.i.d.b.BigQueryDestination(getLoadingMethod):309 - {} - Selected loading method is set to: STANDARD
�[35mdestination�[0m - 2021-11-16 13:42:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:25 �[32mINFO�[m i.a.i.d.b.BigQueryDestination(isKeepFilesInGcs):322 - {} - All tmp files will be removed from GCS when replication is finished
�[35mdestination�[0m - 2021-11-16 13:42:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:27 �[32mINFO�[m i.a.i.d.b.BigQueryUtils(createPartitionedTable):110 - {} - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_jvy_engagements}} created successfully
�[35mdestination�[0m - 2021-11-16 13:42:28 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:28 �[32mINFO�[m i.a.i.d.b.BigQueryUtils(createPartitionedTable):110 - {} - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_nyl_owners}} created successfully
�[35mdestination�[0m - 2021-11-16 13:42:28 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 13:42:28 �[32mINFO�[m i.a.i.d.b.BigQueryUtils(createPartitionedTable):110 - {} - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_cbl_tickets}} created successfully
2021-11-16 13:42:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 1000
2021-11-16 13:42:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 2000
2021-11-16 13:42:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 3000
2021-11-16 13:42:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 4000
2021-11-16 13:43:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 5000
2021-11-16 13:43:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 6000
2021-11-16 13:43:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 7000
2021-11-16 13:43:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 8000
2021-11-16 13:43:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 9000
2021-11-16 13:43:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 10000
2021-11-16 13:43:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 11000
2021-11-16 13:43:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 12000
2021-11-16 13:43:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 13000
2021-11-16 13:44:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 14000
2021-11-16 13:44:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 15000
2021-11-16 13:44:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 16000
2021-11-16 13:44:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 17000
2021-11-16 13:44:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 18000
2021-11-16 13:44:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 19000
2021-11-16 13:44:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 20000
2021-11-16 13:44:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 21000
2021-11-16 13:45:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 22000
2021-11-16 13:45:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 23000
2021-11-16 13:45:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 24000
2021-11-16 13:45:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 25000
2021-11-16 13:45:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 26000
2021-11-16 13:45:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 27000
2021-11-16 13:45:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 28000
2021-11-16 13:45:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 29000
2021-11-16 13:45:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 30000
2021-11-16 13:46:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 31000
2021-11-16 13:46:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 32000
2021-11-16 13:46:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 33000
2021-11-16 13:46:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 34000
2021-11-16 13:46:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 35000
2021-11-16 13:46:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 36000
2021-11-16 13:46:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 37000
2021-11-16 13:46:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 38000
2021-11-16 13:46:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 39000
2021-11-16 13:47:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 40000
2021-11-16 13:47:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 41000
2021-11-16 13:47:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 42000
2021-11-16 13:47:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 43000
2021-11-16 13:47:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 44000
2021-11-16 13:47:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 45000
2021-11-16 13:47:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 46000
2021-11-16 13:47:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 47000
2021-11-16 13:47:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 48000
2021-11-16 13:48:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 49000
2021-11-16 13:48:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 50000
2021-11-16 13:48:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 51000
2021-11-16 13:48:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 52000
2021-11-16 13:48:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 53000
2021-11-16 13:48:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 54000
2021-11-16 13:48:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 55000
2021-11-16 13:48:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 56000
2021-11-16 13:48:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 57000
2021-11-16 13:49:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 58000
2021-11-16 13:49:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 59000
2021-11-16 13:49:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 60000
2021-11-16 13:49:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 61000
2021-11-16 13:49:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 62000
2021-11-16 13:49:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 63000
2021-11-16 13:49:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 64000
2021-11-16 13:49:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 65000
2021-11-16 13:49:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 66000
2021-11-16 13:50:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 67000
2021-11-16 13:50:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 68000
2021-11-16 13:50:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 69000
2021-11-16 13:50:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 70000
2021-11-16 13:50:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 71000
2021-11-16 13:50:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 72000
2021-11-16 13:50:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 73000
2021-11-16 13:50:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 74000
2021-11-16 13:50:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 75000
2021-11-16 13:51:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 76000
2021-11-16 13:51:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 77000
2021-11-16 13:51:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 78000
2021-11-16 13:51:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 79000
2021-11-16 13:51:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 80000
2021-11-16 13:51:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 81000
2021-11-16 13:51:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 82000
2021-11-16 13:51:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 83000
2021-11-16 13:51:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 84000
2021-11-16 13:52:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 85000
2021-11-16 13:52:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 86000
2021-11-16 13:52:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 87000
2021-11-16 13:52:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 88000
2021-11-16 13:52:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 89000
2021-11-16 13:52:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 90000
2021-11-16 13:52:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 91000
2021-11-16 13:52:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 92000
2021-11-16 13:52:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 93000
2021-11-16 13:53:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 94000
2021-11-16 13:53:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 95000
2021-11-16 13:53:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 96000
2021-11-16 13:53:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 97000
2021-11-16 13:53:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 98000
2021-11-16 13:53:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 99000
2021-11-16 13:53:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 100000
2021-11-16 13:53:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 101000
2021-11-16 13:53:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 102000
2021-11-16 13:54:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 103000
2021-11-16 13:54:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 104000
2021-11-16 13:54:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 105000
2021-11-16 13:54:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 106000
2021-11-16 13:54:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 107000
2021-11-16 13:54:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 108000
2021-11-16 13:54:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 109000
2021-11-16 13:54:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 110000
2021-11-16 13:54:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 111000
2021-11-16 13:55:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 112000
2021-11-16 13:55:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 113000
2021-11-16 13:55:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 114000
2021-11-16 13:55:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 115000
2021-11-16 13:55:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 116000
2021-11-16 13:55:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 117000
2021-11-16 13:55:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 118000
2021-11-16 13:55:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 119000
2021-11-16 13:56:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 120000
2021-11-16 13:56:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 121000
2021-11-16 13:56:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 122000
2021-11-16 13:56:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 123000
2021-11-16 13:56:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 124000
2021-11-16 13:56:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 125000
2021-11-16 13:56:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 126000
2021-11-16 13:56:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 127000
2021-11-16 13:56:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 128000
2021-11-16 13:57:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 129000
2021-11-16 13:57:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 130000
2021-11-16 13:57:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 131000
2021-11-16 13:57:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 132000
2021-11-16 13:57:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 133000
2021-11-16 13:57:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 134000
2021-11-16 13:57:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 135000
2021-11-16 13:57:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 136000
2021-11-16 13:57:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 137000
2021-11-16 13:58:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 138000
2021-11-16 13:58:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 139000
2021-11-16 13:58:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 140000
2021-11-16 13:58:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 141000
2021-11-16 13:58:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 142000
2021-11-16 13:58:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 143000
2021-11-16 13:58:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 144000
2021-11-16 13:58:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 145000
2021-11-16 13:59:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 146000
2021-11-16 13:59:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 147000
2021-11-16 13:59:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 148000
2021-11-16 13:59:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 149000
2021-11-16 13:59:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 150000
2021-11-16 13:59:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 151000
2021-11-16 13:59:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 152000
2021-11-16 13:59:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 153000
2021-11-16 14:00:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 154000
2021-11-16 14:00:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 155000
2021-11-16 14:00:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 156000
2021-11-16 14:00:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 157000
2021-11-16 14:00:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 158000
2021-11-16 14:00:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 159000
2021-11-16 14:00:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 160000
2021-11-16 14:00:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 161000
2021-11-16 14:01:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 162000
2021-11-16 14:01:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 163000
2021-11-16 14:01:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 164000
2021-11-16 14:01:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 165000
2021-11-16 14:01:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 166000
2021-11-16 14:01:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 167000
2021-11-16 14:01:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 168000
2021-11-16 14:01:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 169000
2021-11-16 14:02:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 170000
2021-11-16 14:02:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 171000
2021-11-16 14:02:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 172000
2021-11-16 14:02:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 173000
2021-11-16 14:02:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 174000
2021-11-16 14:02:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 175000
2021-11-16 14:02:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 176000
2021-11-16 14:02:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 177000
2021-11-16 14:03:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 178000
2021-11-16 14:03:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 179000
2021-11-16 14:03:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 180000
2021-11-16 14:03:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 181000
2021-11-16 14:03:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 182000
2021-11-16 14:03:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 183000
2021-11-16 14:03:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 184000
2021-11-16 14:03:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 185000
2021-11-16 14:04:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 186000
2021-11-16 14:04:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 187000
2021-11-16 14:04:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 188000
2021-11-16 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 189000
2021-11-16 14:04:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 190000
2021-11-16 14:04:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 191000
2021-11-16 14:04:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 192000
2021-11-16 14:04:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 193000
2021-11-16 14:05:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 194000
2021-11-16 14:05:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 195000
2021-11-16 14:05:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 196000
2021-11-16 14:05:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 197000
2021-11-16 14:05:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 198000
2021-11-16 14:05:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 199000
2021-11-16 14:05:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 200000
2021-11-16 14:05:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 201000
2021-11-16 14:05:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 202000
2021-11-16 14:06:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 203000
2021-11-16 14:06:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 204000
2021-11-16 14:06:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 205000
2021-11-16 14:06:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 206000
2021-11-16 14:06:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 207000
2021-11-16 14:06:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 208000
2021-11-16 14:06:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 209000
2021-11-16 14:06:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 210000
2021-11-16 14:07:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 211000
2021-11-16 14:07:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 212000
2021-11-16 14:07:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 213000
2021-11-16 14:07:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 214000
2021-11-16 14:07:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 215000
2021-11-16 14:07:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 216000
2021-11-16 14:07:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 217000
2021-11-16 14:07:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 218000
2021-11-16 14:08:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 219000
2021-11-16 14:08:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 220000
2021-11-16 14:08:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 221000
2021-11-16 14:08:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 222000
2021-11-16 14:08:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 223000
2021-11-16 14:08:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 224000
2021-11-16 14:08:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 225000
2021-11-16 14:08:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 226000
2021-11-16 14:09:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 227000
2021-11-16 14:09:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 228000
2021-11-16 14:09:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 229000
2021-11-16 14:09:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 230000
2021-11-16 14:09:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 231000
2021-11-16 14:09:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 232000
2021-11-16 14:09:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 233000
2021-11-16 14:09:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 234000
2021-11-16 14:10:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 235000
2021-11-16 14:10:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 236000
2021-11-16 14:10:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 237000
2021-11-16 14:10:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 238000
2021-11-16 14:10:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 239000
2021-11-16 14:10:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 240000
2021-11-16 14:10:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 241000
2021-11-16 14:11:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 242000
2021-11-16 14:11:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 243000
2021-11-16 14:11:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 244000
2021-11-16 14:11:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 245000
2021-11-16 14:11:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 246000
2021-11-16 14:11:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 247000
2021-11-16 14:11:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 248000
2021-11-16 14:11:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 249000
2021-11-16 14:12:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 250000
2021-11-16 14:12:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 251000
2021-11-16 14:12:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 252000
2021-11-16 14:12:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 253000
2021-11-16 14:12:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 254000
2021-11-16 14:12:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 255000
2021-11-16 14:12:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 256000
2021-11-16 14:12:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 257000
2021-11-16 14:13:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 258000
2021-11-16 14:13:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 259000
2021-11-16 14:13:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 260000
2021-11-16 14:13:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 261000
2021-11-16 14:13:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 262000
2021-11-16 14:13:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 263000
2021-11-16 14:13:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 264000
2021-11-16 14:13:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 265000
2021-11-16 14:14:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 266000
2021-11-16 14:14:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 267000
2021-11-16 14:14:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 268000
2021-11-16 14:14:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 269000
2021-11-16 14:14:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 270000
2021-11-16 14:14:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 271000
2021-11-16 14:14:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 272000
2021-11-16 14:15:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 273000
2021-11-16 14:15:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 274000
2021-11-16 14:15:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 275000
2021-11-16 14:15:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 276000
2021-11-16 14:15:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 277000
2021-11-16 14:15:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 278000
2021-11-16 14:15:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 279000
2021-11-16 14:15:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 280000
2021-11-16 14:16:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 281000
2021-11-16 14:16:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 282000
2021-11-16 14:16:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 283000
2021-11-16 14:16:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 284000
2021-11-16 14:16:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 285000
2021-11-16 14:16:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 286000
2021-11-16 14:16:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 287000
2021-11-16 14:16:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 288000
2021-11-16 14:17:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 289000
2021-11-16 14:17:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 290000
2021-11-16 14:17:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 291000
2021-11-16 14:17:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 292000
2021-11-16 14:17:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 293000
2021-11-16 14:17:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 294000
2021-11-16 14:17:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 295000
2021-11-16 14:17:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 296000
2021-11-16 14:18:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 297000
2021-11-16 14:18:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 298000
2021-11-16 14:18:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 299000
2021-11-16 14:18:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 300000
2021-11-16 14:18:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 301000
2021-11-16 14:18:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 302000
2021-11-16 14:18:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 303000
2021-11-16 14:18:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 304000
2021-11-16 14:18:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 305000
2021-11-16 14:19:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 306000
2021-11-16 14:19:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 307000
2021-11-16 14:19:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 308000
2021-11-16 14:19:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 309000
2021-11-16 14:19:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 310000
2021-11-16 14:19:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 311000
2021-11-16 14:19:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 312000
2021-11-16 14:19:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 313000
2021-11-16 14:19:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 314000
2021-11-16 14:20:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 315000
2021-11-16 14:20:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 316000
2021-11-16 14:20:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 317000
2021-11-16 14:20:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 318000
2021-11-16 14:20:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 319000
2021-11-16 14:20:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 320000
2021-11-16 14:20:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 321000
2021-11-16 14:20:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 322000
2021-11-16 14:20:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 323000
2021-11-16 14:21:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 324000
2021-11-16 14:21:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 325000
2021-11-16 14:21:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 326000
2021-11-16 14:21:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 327000
2021-11-16 14:21:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 328000
2021-11-16 14:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 329000
2021-11-16 14:21:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 330000
2021-11-16 14:21:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 331000
2021-11-16 14:21:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 332000
2021-11-16 14:22:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 333000
2021-11-16 14:22:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 334000
2021-11-16 14:22:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 335000
2021-11-16 14:22:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 336000
2021-11-16 14:22:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 337000
2021-11-16 14:22:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 338000
2021-11-16 14:22:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 339000
2021-11-16 14:22:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 340000
2021-11-16 14:22:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 341000
2021-11-16 14:23:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 342000
2021-11-16 14:23:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 343000
2021-11-16 14:23:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 344000
2021-11-16 14:23:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 345000
2021-11-16 14:23:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 346000
2021-11-16 14:23:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 347000
2021-11-16 14:23:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 348000
2021-11-16 14:23:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 349000
2021-11-16 14:23:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 350000
2021-11-16 14:24:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 351000
2021-11-16 14:24:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 352000
2021-11-16 14:24:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 353000
2021-11-16 14:24:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 354000
2021-11-16 14:24:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 355000
2021-11-16 14:24:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 356000
2021-11-16 14:24:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 357000
2021-11-16 14:24:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 358000
2021-11-16 14:25:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 359000
2021-11-16 14:25:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 360000
2021-11-16 14:25:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 361000
2021-11-16 14:25:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 362000
2021-11-16 14:25:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 363000
2021-11-16 14:25:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 364000
2021-11-16 14:25:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 365000
2021-11-16 14:25:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 366000
2021-11-16 14:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 367000
2021-11-16 14:26:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 368000
2021-11-16 14:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 369000
2021-11-16 14:26:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 370000
2021-11-16 14:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 371000
2021-11-16 14:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 372000
2021-11-16 14:26:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 373000
2021-11-16 14:26:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 374000
2021-11-16 14:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 375000
2021-11-16 14:27:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 376000
2021-11-16 14:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 377000
2021-11-16 14:27:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 378000
2021-11-16 14:27:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 379000
2021-11-16 14:27:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 380000
2021-11-16 14:27:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 381000
2021-11-16 14:27:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 382000
2021-11-16 14:27:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 383000
2021-11-16 14:28:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 384000
2021-11-16 14:28:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 385000
2021-11-16 14:28:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 386000
2021-11-16 14:28:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 387000
2021-11-16 14:28:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 388000
2021-11-16 14:28:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 389000
2021-11-16 14:28:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 390000
2021-11-16 14:28:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 391000
2021-11-16 14:29:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 392000
2021-11-16 14:29:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 393000
2021-11-16 14:29:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 394000
2021-11-16 14:29:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 395000
2021-11-16 14:29:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 396000
2021-11-16 14:29:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 397000
2021-11-16 14:29:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 398000
2021-11-16 14:29:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 399000
2021-11-16 14:29:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 400000
2021-11-16 14:30:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 401000
2021-11-16 14:30:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 402000
2021-11-16 14:30:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 403000
2021-11-16 14:30:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 404000
2021-11-16 14:30:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 405000
2021-11-16 14:30:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 406000
2021-11-16 14:30:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 407000
2021-11-16 14:31:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 408000
2021-11-16 14:31:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 409000
2021-11-16 14:31:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 410000
2021-11-16 14:31:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 411000
2021-11-16 14:31:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 412000
2021-11-16 14:31:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 413000
2021-11-16 14:31:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 414000
2021-11-16 14:31:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 415000
2021-11-16 14:32:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 416000
2021-11-16 14:32:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 417000
2021-11-16 14:32:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 418000
2021-11-16 14:32:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 419000
2021-11-16 14:32:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 420000
2021-11-16 14:32:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 421000
2021-11-16 14:32:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 422000
2021-11-16 14:32:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 423000
2021-11-16 14:33:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 424000
2021-11-16 14:33:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 425000
2021-11-16 14:33:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 426000
2021-11-16 14:33:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 427000
2021-11-16 14:33:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 428000
2021-11-16 14:33:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 429000
2021-11-16 14:33:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 430000
2021-11-16 14:33:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 431000
2021-11-16 14:33:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 432000
2021-11-16 14:34:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 433000
2021-11-16 14:34:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 434000
2021-11-16 14:34:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 435000
2021-11-16 14:34:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 436000
2021-11-16 14:34:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 437000
2021-11-16 14:34:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 438000
2021-11-16 14:34:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 439000
2021-11-16 14:34:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 440000
2021-11-16 14:35:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 441000
2021-11-16 14:35:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 442000
2021-11-16 14:35:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 443000
2021-11-16 14:35:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 444000
2021-11-16 14:35:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 445000
2021-11-16 14:35:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 446000
2021-11-16 14:35:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 447000
2021-11-16 14:35:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 448000
2021-11-16 14:36:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 449000
2021-11-16 14:36:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 450000
2021-11-16 14:36:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 451000
2021-11-16 14:36:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 452000
2021-11-16 14:36:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 453000
2021-11-16 14:36:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 454000
2021-11-16 14:36:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 455000
2021-11-16 14:36:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 456000
2021-11-16 14:37:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 457000
2021-11-16 14:37:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 458000
2021-11-16 14:37:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 459000
2021-11-16 14:37:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 460000
2021-11-16 14:37:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 461000
2021-11-16 14:37:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 462000
2021-11-16 14:37:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 463000
2021-11-16 14:37:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 464000
2021-11-16 14:38:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 465000
2021-11-16 14:38:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 466000
2021-11-16 14:38:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 467000
2021-11-16 14:38:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 468000
2021-11-16 14:38:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 469000
2021-11-16 14:38:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 470000
2021-11-16 14:38:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 471000
2021-11-16 14:38:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 472000
2021-11-16 14:38:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 473000
2021-11-16 14:39:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 474000
2021-11-16 14:39:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 475000
2021-11-16 14:39:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 476000
2021-11-16 14:39:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 477000
2021-11-16 14:39:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 478000
2021-11-16 14:39:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 479000
2021-11-16 14:39:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 480000
2021-11-16 14:39:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 481000
2021-11-16 14:40:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 482000
2021-11-16 14:40:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 483000
2021-11-16 14:40:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 484000
2021-11-16 14:40:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 485000
2021-11-16 14:40:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 486000
2021-11-16 14:40:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 487000
2021-11-16 14:40:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 488000
2021-11-16 14:40:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 489000
2021-11-16 14:41:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 490000
2021-11-16 14:41:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 491000
2021-11-16 14:41:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 492000
2021-11-16 14:41:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 493000
2021-11-16 14:41:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 494000
2021-11-16 14:41:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 495000
2021-11-16 14:41:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 496000
2021-11-16 14:41:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 497000
2021-11-16 14:41:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 498000
2021-11-16 14:42:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 499000
2021-11-16 14:42:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 500000
2021-11-16 14:42:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 501000
2021-11-16 14:42:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 502000
2021-11-16 14:42:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 503000
2021-11-16 14:42:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 504000
2021-11-16 14:43:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 505000
2021-11-16 14:43:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 506000
2021-11-16 14:43:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 507000
2021-11-16 14:43:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 508000
2021-11-16 14:43:36 INFO () DefaultReplicationWorker(run):121 - Source thread complete.
2021-11-16 14:43:36 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join.
�[35mdestination�[0m - 2021-11-16 14:43:36 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:43:36 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded.
�[35mdestination�[0m - 2021-11-16 14:43:36 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:43:36 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(close):163 - {} - Started closing all connections
�[35mdestination�[0m - 2021-11-16 14:43:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:43:37 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(closeNormalBigqueryStreams):278 - {} - Waiting for jobs to be finished/closed
�[35mdestination�[0m - 2021-11-16 14:44:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:17 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(closeNormalBigqueryStreams):295 - {} - Replication finished with no explicit errors. Copying data from tmp tables to permanent
�[35mdestination�[0m - 2021-11-16 14:44:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:19 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(copyTable):363 - {} - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_nyl_owners}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_raw_owners}}
�[35mdestination�[0m - 2021-11-16 14:44:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:20 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(copyTable):363 - {} - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_cbl_tickets}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_raw_tickets}}
�[35mdestination�[0m - 2021-11-16 14:44:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:23 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(copyTable):363 - {} - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_tmp_jvy_engagements}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=hubspot, tableId=_airbyte_raw_engagements}}
2021-11-16 14:44:23 INFO () JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $: null found, object expected
2021-11-16 14:44:23 ERROR () DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null
�[35mdestination�[0m - 2021-11-16 14:44:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:23 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(closeNormalBigqueryStreams):312 - {} - Removing tmp tables...
�[35mdestination�[0m - 2021-11-16 14:44:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:23 �[32mINFO�[m i.a.i.d.b.BigQueryRecordConsumer(closeNormalBigqueryStreams):314 - {} - Finishing destination process...completed
�[35mdestination�[0m - 2021-11-16 14:44:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:23 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
�[35mdestination�[0m - 2021-11-16 14:44:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-16 14:44:23 �[32mINFO�[m i.a.i.d.b.BigQueryDestination(main):336 - {} - completed destination: class io.airbyte.integrations.destination.bigquery.BigQueryDestination
2021-11-16 14:44:23 INFO () DefaultReplicationWorker(run):124 - Destination thread complete.
2021-11-16 14:44:23 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@34d5320d[status=completed,recordsSynced=508361,bytesSynced=6107276766,startTime=1637070141184,endTime=1637073863875]
2021-11-16 14:44:23 INFO () DefaultReplicationWorker(run):161 - Source did not output any state messages
2021-11-16 14:44:23 WARN () DefaultReplicationWorker(run):169 - State capture: No new state, falling back on input state: io.airbyte.config.State@7320b943[state={}]
2021-11-16 14:44:23 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2021-11-16 14:44:23 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):233 - sync summary: io.airbyte.config.StandardSyncOutput@5980396a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@3cc822cf[status=completed,recordsSynced=508361,bytesSynced=6107276766,startTime=1637070141184,endTime=1637073863875],state=io.airbyte.config.State@7320b943[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5183ac2b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5dd36eb[stream=io.airbyte.protocol.models.AirbyteStream@5dce0453[name=engagements,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"type":{"type":["null","string"]},"active":{"type":["null","boolean"]},"ownerId":{"type":["null","integer"]},"metadata":{"type":["null","object"],"properties":{"cc":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"email":{"type":["null","string"]}}}},"to":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"email":{"type":["null","string"]}}}},"bcc":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"email":{"type":["null","string"]}}}},"body":{"type":["null","string"]},"from":{"type":["null","object"],"properties":{"email":{"type":["null","string"]},"lastName":{"type":["null","string"]},"firstName":{"type":["null","string"]}}},"html":{"type":["null","string"]},"text":{"type":["null","string"]},"title":{"type":["null","string"]},"status":{"type":["null","string"]},"endTime":{"type":["null","integer"]},"subject":{"type":["null","string"]},"toNumber":{"type":["null","string"]},"startTime":{"type":["null","integer"]},"externalId":{"type":["null","string"]},"fromNumber":{"type":["null","string"]},"disposition":{"type":["null","string"]},"recordingUrl":{"type":["null","string"]},"forObjectType":{"type":["null","string"]},"externalAccountId":{"type":["null","string"]},"durationMilliseconds":{"type":["null","integer"]}}},"portalId":{"type":["null","integer"]},"createdAt":{"type":["null","integer"]},"timestamp":{"type":["null","integer"]},"properties":{"type":"object","properties":{"hs_call_body":{"type":["null","string"]},"hs_i_cal_uid":{"type":["null","string"]},"hs_note_body":{"type":["null","string"]},"hs_object_id":{"type":["null","number"]},"hs_task_body":{"type":["null","string"]},"hs_task_type":{"type":["null","string"]},"hs_timestamp":{"type":["null","string"],"format":"date-time"},"hs_unique_id":{"type":["null","string"]},"hs_call_title":{"type":["null","string"]},"hs_created_by":{"type":["null","string"]},"hs_createdate":{"type":["null","string"],"format":"date-time"},"hs_email_html":{"type":["null","string"]},"hs_email_text":{"type":["null","string"]},"hs_call_app_id":{"type":["null","number"]},"hs_call_source":{"type":["null","string"]},"hs_call_status":{"type":["null","string"]},"hs_modified_by":{"type":["null","string"]},"hs_task_status":{"type":["null","string"]},"hs_all_team_ids":{"type":["null","string"]},"hs_body_preview":{"type":["null","string"]},"hs_email_cc_raw":{"type":["null","string"]},"hs_email_status":{"type":["null","string"]},"hs_email_to_raw":{"type":["null","string"]},"hs_gdpr_deleted":{"type":["null","boolean"]},"hs_meeting_body":{"type":["null","string"]},"hs_product_name":{"type":["null","string"]},"hs_task_subject":{"type":["null","string"]},"hubspot_team_id":{"type":["null","string"]},"hs_activity_type":{"type":["null","string"]},"hs_all_owner_ids":{"type":["null","string"]},"hs_call_duration":{"type":["null","number"]},"hs_email_bcc_raw":{"type":["null","string"]},"hs_email_headers":{"type":["null","string"]},"hs_email_subject":{"type":["null","string"]},"hs_meeting_title":{"type":["null","string"]},"hs_task_priority":{"type":["null","string"]},"hubspot_owner_id":{"type":["null","string"]},"hs_attachment_ids":{"type":["null","string"]},"hs_call_to_number":{"type":["null","string"]},"hs_email_cc_email":{"type":["null","string"]},"hs_email_from_raw":{"type":["null","string"]},"hs_email_sent_via":{"type":["null","string"]},"hs_email_to_email":{"type":["null","string"]},"hs_meeting_source":{"type":["null","string"]},"hs_task_reminders":{"type":["null","string"]},"hs_email_bcc_email":{"type":["null","string"]},"hs_email_direction":{"type":["null","string"]},"hs_email_thread_id":{"type":["null","string"]},"hs_engagement_type":{"type":["null","string"]},"hs_meeting_outcome":{"type":["null","string"]},"hs_scheduled_tasks":{"type":["null","string"]},"hs_task_is_all_day":{"type":["null","boolean"]},"hs_call_disposition":{"type":["null","string"]},"hs_call_external_id":{"type":["null","string"]},"hs_call_from_number":{"type":["null","string"]},"hs_email_from_email":{"type":["null","string"]},"hs_email_message_id":{"type":["null","string"]},"hs_email_sender_raw":{"type":["null","string"]},"hs_follow_up_action":{"type":["null","string"]},"hs_lastmodifieddate":{"type":["null","string"],"format":"date-time"},"hs_meeting_end_time":{"type":["null","string"],"format":"date-time"},"hs_meeting_location":{"type":["null","string"]},"hs_task_template_id":{"type":["null","number"]},"hs_body_preview_html":{"type":["null","string"]},"hs_calendar_event_id":{"type":["null","string"]},"hs_email_cc_lastname":{"type":["null","string"]},"hs_email_logged_from":{"type":["null","string"]},"hs_email_to_lastname":{"type":["null","string"]},"hs_email_tracker_key":{"type":["null","string"]},"hs_engagement_source":{"type":["null","string"]},"hs_meeting_change_id":{"type":["null","string"]},"hs_meeting_source_id":{"type":["null","string"]},"hs_merged_object_ids":{"type":["null","string"]},"hs_call_recording_url":{"type":["null","string"]},"hs_created_by_user_id":{"type":["null","number"]},"hs_email_bcc_lastname":{"type":["null","string"]},"hs_email_cc_firstname":{"type":["null","string"]},"hs_email_sender_email":{"type":["null","string"]},"hs_email_to_firstname":{"type":["null","string"]},"hs_meeting_start_time":{"type":["null","string"],"format":"date-time"},"hs_msteams_message_id":{"type":["null","string"]},"hs_updated_by_user_id":{"type":["null","number"]},"hs_call_has_transcript":{"type":["null","boolean"]},"hs_email_bcc_firstname":{"type":["null","string"]},"hs_email_error_message":{"type":["null","string"]},"hs_email_from_lastname":{"type":["null","string"]},"hs_email_send_event_id":{"type":["null","string"]},"hs_unique_creation_key":{"type":["null","string"]},"hs_email_from_firstname":{"type":["null","string"]},"hs_engagement_source_id":{"type":["null","string"]},"hs_meeting_external_url":{"type":["null","string"]},"hs_num_associated_deals":{"type":["null","number"]},"hs_publishing_task_body":{"type":["null","string"]},"hs_publishing_task_name":{"type":["null","string"]},"hs_queue_membership_ids":{"type":["null","string"]},"hs_task_completion_date":{"type":["null","string"],"format":"date-time"},"hs_task_for_object_type":{"type":["null","string"]},"hs_task_repeat_interval":{"type":["null","string"]},"hs_call_callee_object_id":{"type":["null","number"]},"hs_call_transcription_id":{"type":["null","number"]},"hs_calls_service_call_id":{"type":["null","number"]},"hs_email_sender_lastname":{"type":["null","string"]},"hs_publishing_task_state":{"type":["null","string"]},"hs_task_contact_timezone":{"type":["null","string"]},"hs_at_mentioned_owner_ids":{"type":["null","string"]},"hs_call_zoom_meeting_uuid":{"type":["null","string"]},"hs_email_post_send_status":{"type":["null","string"]},"hs_email_sender_firstname":{"type":["null","string"]},"hs_internal_meeting_notes":{"type":["null","string"]},"hs_num_associated_tickets":{"type":["null","number"]},"hs_user_ids_of_all_owners":{"type":["null","string"]},"hs_all_accessible_team_ids":{"type":["null","string"]},"hs_call_callee_object_type":{"type":["null","string"]},"hs_direction_and_unique_id":{"type":["null","string"]},"hs_email_attached_video_id":{"type":["null","string"]},"hs_email_facsimile_send_id":{"type":["null","string"]},"hs_num_associated_contacts":{"type":["null","number"]},"hs_task_relative_reminders":{"type":["null","string"]},"hubspot_owner_assigneddate":{"type":["null","string"],"format":"date-time"},"hs_call_authed_url_provider":{"type":["null","string"]},"hs_call_external_account_id":{"type":["null","string"]},"hs_call_video_recording_url":{"type":["null","string"]},"hs_conversation_session_url":{"type":["null","string"]},"hs_email_validation_skipped":{"type":["null","string"]},"hs_num_associated_companies":{"type":["null","number"]},"hs_publishing_task_category":{"type":["null","string"]},"hs_task_sequence_step_order":{"type":["null","number"]},"hs_body_preview_is_truncated":{"type":["null","boolean"]},"hs_email_attached_video_name":{"type":["null","string"]},"hs_publishing_task_content_id":{"type":["null","string"]},"hs_task_last_contact_outreach":{"type":["null","string"],"format":"date-time"},"hs_task_send_default_reminder":{"type":["null","boolean"]},"hs_conversation_session_is_bot":{"type":["null","boolean"]},"hs_conversation_session_online":{"type":["null","boolean"]},"hs_conversation_session_source":{"type":["null","string"]},"hs_email_attached_video_opened":{"type":["null","boolean"]},"hs_email_send_event_id_created":{"type":["null","string"],"format":"date-time"},"hs_meeting_calendar_event_hash":{"type":["null","string"]},"hs_publishing_task_category_id":{"type":["null","number"]},"hs_email_attached_video_watched":{"type":["null","boolean"]},"hs_email_recipient_drop_reasons":{"type":["null","string"]},"hs_meeting_created_from_link_id":{"type":["null","string"]},"hs_num_associated_queue_objects":{"type":["null","number"]},"hs_task_probability_to_complete":{"type":["null","number"]},"hs_unknown_visitor_conversation":{"type":["null","boolean"]},"hs_conversation_session_duration":{"type":["null","number"]},"hs_email_media_processing_status":{"type":["null","string"]},"hs_publishing_task_campaign_guid":{"type":["null","string"]},"hs_all_assigned_business_unit_ids":{"type":["null","string"]},"hs_conversation_session_thread_id":{"type":["null","number"]},"hs_email_pending_inline_image_ids":{"type":["null","string"]},"hs_task_sequence_enrollment_active":{"type":["null","boolean"]},"hs_publishing_task_campaign_step_id":{"type":["null","string"]},"hs_task_sequence_step_enrollment_id":{"type":["null","string"]},"hs_meeting_web_conference_meeting_id":{"type":["null","string"]},"hs_task_last_sales_activity_timestamp":{"type":["null","string"],"format":"date-time"},"hs_email_member_of_forwarded_subthread":{"type":["null","boolean"]},"hs_conversation_session_agent_join_time":{"type":["null","string"],"format":"date-time"},"hs_conversation_session_visitor_end_time":{"type":["null","string"],"format":"date-time"},"hs_conversation_session_session_closed_at":{"type":["null","string"],"format":"date-time"},"hs_conversation_session_visitor_wait_time":{"type":["null","number"]},"hs_meeting_pre_meeting_prospect_reminders":{"type":["null","string"]},"hs_user_ids_of_all_notification_followers":{"type":["null","string"]},"hs_conversation_session_num_agent_messages":{"type":["null","number"]},"hs_conversation_session_visitor_start_time":{"type":["null","string"],"format":"date-time"},"hs_conversation_session_agent_response_time":{"type":["null","number"]},"hs_email_encoded_email_associations_request":{"type":["null","string"]},"hs_email_migrated_via_portal_data_migration":{"type":["null","string"]},"hs_user_ids_of_all_notification_unfollowers":{"type":["null","string"]},"hs_conversation_session_num_visitor_messages":{"type":["null","number"]}}},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]}}}},"lastUpdated":{"type":["null","integer"]},"associations":{"type":["null","object"],"properties":{"dealIds":{"type":["null","array"],"items":{"type":["null","integer"]}},"companyIds":{"type":["null","array"],"items":{"type":["null","integer"]}},"contactIds":{"type":["null","array"],"items":{"type":["null","integer"]}}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[lastUpdated],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[lastUpdated],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@206d9b7f[stream=io.airbyte.protocol.models.AirbyteStream@6c4399ad[name=owners,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"email":{"type":["null","string"]},"teams":{"type":["null","array"],"items":{"type":"object","properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"membership":{"type":["null","string"]}}}},"userId":{"type":["null","integer"]},"archived":{"type":["null","boolean"]},"lastName":{"type":["null","string"]},"createdAt":{"type":["null","string"],"format":"date-time"},"firstName":{"type":["null","string"]},"updatedAt":{"type":["null","string"],"format":"date-time"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4590a0[stream=io.airbyte.protocol.models.AirbyteStream@2d04e067[name=tickets,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"archived":{"type":["null","boolean"]},"createdAt":{"type":["null","string"],"format":"date-time"},"updatedAt":{"type":["null","string"],"format":"date-time"},"properties":{"type":"object","properties":{"tags":{"type":["null","string"]},"content":{"type":["null","string"]},"subject":{"type":["null","string"]},"goodwill":{"type":["null","number"]},"ab_nummer":{"type":["null","string"]},"deal_type":{"type":["null","string"]},"nps_score":{"type":["null","string"]},"num_notes":{"type":["null","number"]},"created_by":{"type":["null","number"]},"createdate":{"type":["null","string"],"format":"date-time"},"source_ref":{"type":["null","string"]},"batch_sizes":{"type":["null","string"]},"closed_date":{"type":["null","string"],"format":"date-time"},"hs_pipeline":{"type":["null","string"]},"part_length":{"type":["null","string"]},"source_type":{"type":["null","string"]},"deal_revenue":{"type":["null","number"]},"hs_object_id":{"type":["null","number"]},"hs_ticket_id":{"type":["null","number"]},"hs_time_in_1":{"type":["null","number"]},"hs_time_in_2":{"type":["null","number"]},"hs_time_in_3":{"type":["null","number"]},"hs_time_in_4":{"type":["null","number"]},"product_type":{"type":["null","string"]},"solving_time":{"type":["null","string"]},"target_price":{"type":["null","string"]},"affected_team":{"type":["null","string"]},"claim_outcome":{"type":["null","string"]},"cost_producer":{"type":["null","number"]},"delivery_date":{"type":["null","string"],"format":"date-time"},"hs_createdate":{"type":["null","string"],"format":"date-time"},"hs_resolution":{"type":["null","string"]},"time_to_close":{"type":["null","number"]},"categorization":{"type":["null","string"]},"cause_of_claim":{"type":["null","string"]},"discount_value":{"type":["null","number"]},"hs_file_upload":{"type":["null","string"]},"margin_on_deal":{"type":["null","number"]},"producer_price":{"type":["null","number"]},"scope_of_claim":{"type":["null","string"]},"claim_reason_lh":{"type":["null","string"]},"discount_reason":{"type":["null","string"]},"discount_ticket":{"type":["null","string"]},"hs_all_team_ids":{"type":["null","string"]},"hs_custom_inbox":{"type":["null","number"]},"hubspot_deal_id":{"type":["null","number"]},"hubspot_team_id":{"type":["null","string"]},"last_reply_date":{"type":["null","string"],"format":"date-time"},"upload_pictures":{"type":["null","string"]},"customer_request":{"type":["null","string"]},"hs_all_owner_ids":{"type":["null","string"]},"hs_date_exited_1":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3":{"type":["null","string"],"format":"date-time"},"hs_date_exited_4":{"type":["null","string"],"format":"date-time"},"hs_lastcontacted":{"type":["null","string"],"format":"date-time"},"hubspot_owner_id":{"type":["null","string"]},"kind_of_machines":{"type":["null","string"]},"product_type_tam":{"type":["null","string"]},"source_thread_id":{"type":["null","string"]},"type_of_incident":{"type":["null","string"]},"claim_description":{"type":["null","string"]},"hs_date_entered_1":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3":{"type":["null","string"],"format":"date-time"},"hs_date_entered_4":{"type":["null","string"],"format":"date-time"},"hs_pipeline_stage":{"type":["null","string"]},"hs_time_in_494381":{"type":["null","number"]},"hs_time_in_494382":{"type":["null","number"]},"hs_time_in_494383":{"type":["null","number"]},"hs_time_in_494384":{"type":["null","number"]},"incident_solution":{"type":["null","string"]},"logistic_costs_lh":{"type":["null","number"]},"hs_last_email_date":{"type":["null","string"],"format":"date-time"},"hs_ticket_category":{"type":["null","string"]},"hs_ticket_priority":{"type":["null","string"]},"hs_time_in_2058831":{"type":["null","number"]},"hs_time_in_2278955":{"type":["null","number"]},"hs_time_in_2278956":{"type":["null","number"]},"hs_time_in_2278957":{"type":["null","number"]},"hs_time_in_2278958":{"type":["null","number"]},"hs_time_in_2278959":{"type":["null","number"]},"hs_time_in_2278960":{"type":["null","number"]},"hs_time_in_2521633":{"type":["null","number"]},"hs_time_in_2521634":{"type":["null","number"]},"hs_time_in_2802311":{"type":["null","number"]},"hs_time_in_2802321":{"type":["null","number"]},"hs_time_in_2856712":{"type":["null","number"]},"hs_time_in_2953546":{"type":["null","number"]},"hs_time_in_2953547":{"type":["null","number"]},"hs_time_in_2953548":{"type":["null","number"]},"hs_time_in_2953549":{"type":["null","number"]},"hs_time_in_2959446":{"type":["null","number"]},"hs_time_in_3414674":{"type":["null","number"]},"hs_time_in_3414675":{"type":["null","number"]},"hs_time_in_3414676":{"type":["null","number"]},"hs_time_in_3414677":{"type":["null","number"]},"hs_time_in_3414690":{"type":["null","number"]},"hs_time_in_3414691":{"type":["null","number"]},"hs_time_in_3414692":{"type":["null","number"]},"hs_time_in_3414693":{"type":["null","number"]},"hs_time_in_3414694":{"type":["null","number"]},"hs_time_in_3414695":{"type":["null","number"]},"hs_time_in_3642542":{"type":["null","number"]},"hs_time_in_3642543":{"type":["null","number"]},"hs_time_in_3642544":{"type":["null","number"]},"hs_time_in_3642545":{"type":["null","number"]},"hs_time_in_3793661":{"type":["null","number"]},"hs_time_in_4877497":{"type":["null","number"]},"hs_time_in_5366687":{"type":["null","number"]},"hs_time_in_5366707":{"type":["null","number"]},"hs_time_in_5381383":{"type":["null","number"]},"hs_time_in_5381384":{"type":["null","number"]},"hs_time_in_5381385":{"type":["null","number"]},"hs_time_in_5381386":{"type":["null","number"]},"hs_time_in_7290254":{"type":["null","number"]},"materials_on_stock":{"type":["null","string"]},"notes_last_updated":{"type":["null","string"],"format":"date-time"},"number_of_machines":{"type":["null","number"]},"categorization_opex":{"type":["null","string"]},"claim_reason_other_":{"type":["null","string"]},"cost_laserhub_claim":{"type":["null","number"]},"cost_of_claim_total":{"type":["null","number"]},"hs_lastactivitydate":{"type":["null","string"],"format":"date-time"},"hs_lastmodifieddate":{"type":["null","string"],"format":"date-time"},"hs_nextactivitydate":{"type":["null","string"],"format":"date-time"},"hs_time_in_10138561":{"type":["null","number"]},"hs_time_in_10138562":{"type":["null","number"]},"hs_time_in_10138563":{"type":["null","number"]},"hs_time_in_10138564":{"type":["null","number"]},"hs_time_in_14144189":{"type":["null","number"]},"hs_time_in_14144190":{"type":["null","number"]},"hs_time_in_14144191":{"type":["null","number"]},"hs_time_in_14144192":{"type":["null","number"]},"hs_time_in_17160339":{"type":["null","number"]},"hs_time_in_17160340":{"type":["null","number"]},"hs_time_in_17160341":{"type":["null","number"]},"hs_time_in_17160342":{"type":["null","number"]},"hs_time_in_17162525":{"type":["null","number"]},"hs_time_in_17797658":{"type":["null","number"]},"hs_time_in_17797659":{"type":["null","number"]},"hs_time_in_17797660":{"type":["null","number"]},"hs_time_in_17797661":{"type":["null","number"]},"lead_time_per_order":{"type":["null","string"]},"num_contacted_notes":{"type":["null","number"]},"number_of_employees":{"type":["null","string"]},"re_factoring_wanted":{"type":["null","string"]},"ticket_entity_count":{"type":["null","number"]},"claimed_goods_usable":{"type":["null","string"]},"cost_logistics_claim":{"type":["null","number"]},"discounted_positions":{"type":["null","string"]},"hs_merged_object_ids":{"type":["null","string"]},"last_engagement_date":{"type":["null","string"],"format":"date-time"},"notes_last_contacted":{"type":["null","string"],"format":"date-time"},"nps_follow_up_answer":{"type":["null","string"]},"erp_system_xml_ready_":{"type":["null","string"]},"hs_created_by_user_id":{"type":["null","number"]},"hs_date_exited_494381":{"type":["null","string"],"format":"date-time"},"hs_date_exited_494382":{"type":["null","string"],"format":"date-time"},"hs_date_exited_494383":{"type":["null","string"],"format":"date-time"},"hs_date_exited_494384":{"type":["null","string"],"format":"date-time"},"hs_msteams_message_id":{"type":["null","string"]},"hs_updated_by_user_id":{"type":["null","number"]},"sales_discount_reason":{"type":["null","string"]},"days_until_refactoring":{"type":["null","number"]},"file_upload_extra_mile":{"type":["null","string"]},"first_agent_reply_date":{"type":["null","string"],"format":"date-time"},"hs_date_entered_494381":{"type":["null","string"],"format":"date-time"},"hs_date_entered_494382":{"type":["null","string"],"format":"date-time"},"hs_date_entered_494383":{"type":["null","string"],"format":"date-time"},"hs_date_entered_494384":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2058831":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278955":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278956":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278957":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278958":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278959":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2278960":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2521633":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2521634":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2802311":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2802321":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2856712":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2953546":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2953547":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2953548":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2953549":{"type":["null","string"],"format":"date-time"},"hs_date_exited_2959446":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414674":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414675":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414676":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414677":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414690":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414691":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414692":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414693":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414694":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3414695":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3642542":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3642543":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3642544":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3642545":{"type":["null","string"],"format":"date-time"},"hs_date_exited_3793661":{"type":["null","string"],"format":"date-time"},"hs_date_exited_4877497":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5366687":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5366707":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5381383":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5381384":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5381385":{"type":["null","string"],"format":"date-time"},"hs_date_exited_5381386":{"type":["null","string"],"format":"date-time"},"hs_date_exited_7290254":{"type":["null","string"],"format":"date-time"},"hs_external_object_ids":{"type":["null","string"]},"hs_last_email_activity":{"type":["null","string"]},"hs_num_times_contacted":{"type":["null","number"]},"hs_unique_creation_key":{"type":["null","string"]},"manufacturing_producer":{"type":["null","string"]},"discount_incl__shipping":{"type":["null","string"]},"hs_date_entered_2058831":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278955":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278956":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278957":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278958":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278959":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2278960":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2521633":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2521634":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2802311":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2802321":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2856712":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2953546":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2953547":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2953548":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2953549":{"type":["null","string"],"format":"date-time"},"hs_date_entered_2959446":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414674":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414675":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414676":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414677":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414690":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414691":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414692":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414693":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414694":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3414695":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3642542":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3642543":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3642544":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3642545":{"type":["null","string"],"format":"date-time"},"hs_date_entered_3793661":{"type":["null","string"],"format":"date-time"},"hs_date_entered_4877497":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5366687":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5366707":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5381383":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5381384":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5381385":{"type":["null","string"],"format":"date-time"},"hs_date_entered_5381386":{"type":["null","string"],"format":"date-time"},"hs_date_entered_7290254":{"type":["null","string"],"format":"date-time"},"hs_date_exited_10138561":{"type":["null","string"],"format":"date-time"},"hs_date_exited_10138562":{"type":["null","string"],"format":"date-time"},"hs_date_exited_10138563":{"type":["null","string"],"format":"date-time"},"hs_date_exited_10138564":{"type":["null","string"],"format":"date-time"},"hs_date_exited_14144189":{"type":["null","string"],"format":"date-time"},"hs_date_exited_14144190":{"type":["null","string"],"format":"date-time"},"hs_date_exited_14144191":{"type":["null","string"],"format":"date-time"},"hs_date_exited_14144192":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17160339":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17160340":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17160341":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17160342":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17162525":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17797658":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17797659":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17797660":{"type":["null","string"],"format":"date-time"},"hs_date_exited_17797661":{"type":["null","string"],"format":"date-time"},"logistics_cost_producer":{"type":["null","number"]},"claim_reason_sheet_metal":{"type":["null","string"]},"hs_date_entered_10138561":{"type":["null","string"],"format":"date-time"},"hs_date_entered_10138562":{"type":["null","string"],"format":"date-time"},"hs_date_entered_10138563":{"type":["null","string"],"format":"date-time"},"hs_date_entered_10138564":{"type":["null","string"],"format":"date-time"},"hs_date_entered_14144189":{"type":["null","string"],"format":"date-time"},"hs_date_entered_14144190":{"type":["null","string"],"format":"date-time"},"hs_date_entered_14144191":{"type":["null","string"],"format":"date-time"},"hs_date_entered_14144192":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17160339":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17160340":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17160341":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17160342":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17162525":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17797658":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17797659":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17797660":{"type":["null","string"],"format":"date-time"},"hs_date_entered_17797661":{"type":["null","string"],"format":"date-time"},"hs_thread_ids_to_restore":{"type":["null","string"]},"notes_next_activity_date":{"type":["null","string"],"format":"date-time"},"hs_user_ids_of_all_owners":{"type":["null","string"]},"time_to_first_agent_reply":{"type":["null","number"]},"conversion_ticket_to_order":{"type":["null","string"]},"hs_all_accessible_team_ids":{"type":["null","string"]},"hubspot_owner_assigneddate":{"type":["null","string"],"format":"date-time"},"positions_to_be_discounted":{"type":["null","string"]},"proposed_solution_customer":{"type":["null","string"]},"bug_files_and_documentation":{"type":["null","string"]},"hs_feedback_last_ces_rating":{"type":["null","string"]},"hs_num_associated_companies":{"type":["null","number"]},"hs_sales_email_last_replied":{"type":["null","string"],"format":"date-time"},"number_of_claimed_positions":{"type":["null","number"]},"hs_feedback_last_survey_date":{"type":["null","string"],"format":"date-time"},"impacted_orders_and_contacts":{"type":["null","string"]},"discount_absolute___percentage":{"type":["null","string"]},"hs_feedback_last_ces_follow_up":{"type":["null","string"]},"nps_follow_up_question_version":{"type":["null","number"]},"claimed_position_and_quantities":{"type":["null","string"]},"self_correction_of_goods_wanted":{"type":["null","string"]},"hs_auto_generated_from_thread_id":{"type":["null","number"]},"manufacturing_process_extra_mile":{"type":["null","string"]},"hs_all_assigned_business_unit_ids":{"type":["null","string"]},"specialization_dimension_producer":{"type":["null","string"]},"documentation_of_incident_solution":{"type":["null","string"]},"hs_originating_email_engagement_id":{"type":["null","number"]},"further_information___finance_discount":{"type":["null","string"]},"hs_conversations_originating_thread_id":{"type":["null","number"]},"hs_conversations_originating_message_id":{"type":["null","string"]},"hs_user_ids_of_all_notification_followers":{"type":["null","string"]},"hs_user_ids_of_all_notification_unfollowers":{"type":["null","string"]}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2021-11-16 14:44:23 INFO () ConfigRepository(updateConnectionState):453 - Updating connection 1a62dd2f-3305-499f-b363-83db8576666c state: io.airbyte.config.State@3d6c01a8[state={}]
2021-11-16 14:44:23 INFO () DatabaseConfigPersistence(updateConfigRecord):236 - Updating STANDARD_SYNC_STATE record 1a62dd2f-3305-499f-b363-83db8576666c
2021-11-16 14:44:24 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2021-11-16 14:44:24 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2021-11-16 14:44:24 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2021-11-16 14:44:24 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2021-11-16 14:44:24 INFO () DefaultNormalizationWorker(run):46 - Running normalization.
2021-11-16 14:44:24 INFO () DefaultNormalizationRunner(runProcess):114 - Running with normalization version: airbyte/normalization:0.1.58
2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.58 exists...
2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - airbyte/normalization:0.1.58 was found locally.
2021-11-16 14:44:24 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/74/0/normalize --network host --log-driver none airbyte/normalization:0.1.58 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json
�[32mnormalization�[0m - 2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - Running: transform-config --config destination_config.json --integration-type bigquery --out /data/74/0/normalize
�[32mnormalization�[0m - 2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - Namespace(config='destination_config.json', integration_type=<DestinationType.bigquery: 'bigquery'>, out='/data/74/0/normalize')
�[32mnormalization�[0m - 2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - transform_bigquery
�[32mnormalization�[0m - 2021-11-16 14:44:24 INFO () LineGobbler(voidCall):82 - Running: transform-catalog --integration-type bigquery --profile-config-dir /data/74/0/normalize --catalog destination_catalog.json --out /data/74/0/normalize/models/generated/ --json-column _airbyte_data
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 - Processing destination_catalog.json...
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_ab1.sql from engagements
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_ab2.sql from engagements
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_ab3.sql from engagements
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements.sql from engagements
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_ab1.sql from owners
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_ab2.sql from owners
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_ab3.sql from owners
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/owners.sql from owners
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_ab1.sql from tickets
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_ab2.sql from tickets
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_ab3.sql from tickets
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/tickets.sql from tickets
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_ab1.sql from engagements/metadata
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_ab2.sql from engagements/metadata
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_ab3.sql from engagements/metadata
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_metadata.sql from engagements/metadata
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_properties_ab1.sql from engagements/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_properties_ab2.sql from engagements/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_properties_ab3.sql from engagements/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_properties.sql from engagements/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_attachments_ab1.sql from engagements/attachments
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_attachments_ab2.sql from engagements/attachments
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_attachments_ab3.sql from engagements/attachments
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_attachments.sql from engagements/attachments
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_associations_ab1.sql from engagements/associations
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_associations_ab2.sql from engagements/associations
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_associations_ab3.sql from engagements/associations
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_associations.sql from engagements/associations
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_teams_ab1.sql from owners/teams
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_teams_ab2.sql from owners/teams
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/owners_teams_ab3.sql from owners/teams
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/owners_teams.sql from owners/teams
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_properties_ab1.sql from tickets/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_properties_ab2.sql from tickets/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/tickets_properties_ab3.sql from tickets/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/tickets_properties.sql from tickets/properties
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_cc_ab1.sql from engagements/metadata/cc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_cc_ab2.sql from engagements/metadata/cc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_cc_ab3.sql from engagements/metadata/cc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_metadata_cc.sql from engagements/metadata/cc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_to_ab1.sql from engagements/metadata/to
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_to_ab2.sql from engagements/metadata/to
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_to_ab3.sql from engagements/metadata/to
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_metadata_to.sql from engagements/metadata/to
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_bcc_ab1.sql from engagements/metadata/bcc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_bcc_ab2.sql from engagements/metadata/bcc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_bcc_ab3.sql from engagements/metadata/bcc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_metadata_bcc.sql from engagements/metadata/bcc
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_from_ab1.sql from engagements/metadata/from
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_from_ab2.sql from engagements/metadata/from
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/hubspot/engagements_metadata_from_ab3.sql from engagements/metadata/from
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/hubspot/engagements_metadata_from.sql from engagements/metadata/from
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Ignoring stream 'dealIds' from engagements/associations/dealIds because properties list is empty
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Ignoring stream 'companyIds' from engagements/associations/companyIds because properties list is empty
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 -   Ignoring stream 'contactIds' from engagements/associations/contactIds because properties list is empty
�[32mnormalization�[0m - 2021-11-16 14:44:25 INFO () LineGobbler(voidCall):82 - detected no config file for ssh, assuming ssh is off.
�[32mnormalization�[0m - 2021-11-16 14:44:27 INFO () LineGobbler(voidCall):82 - Running with dbt=0.21.0
�[32mnormalization�[0m - 2021-11-16 14:44:28 INFO () LineGobbler(voidCall):82 - Unable to do partial parsing because ../build/partial_parse.msgpack not found
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - [�[33mWARNING�[0m]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - There are 2 unused configuration paths:
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_incremental
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_views
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - Found 52 models, 0 tests, 0 snapshots, 0 analyses, 500 macros, 0 operations, 0 seed files, 3 sources, 0 exposures
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 14:44:31 | Concurrency: 32 threads (target='prod')
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 14:44:31 | 
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 14:44:31 | 1 of 13 START table model hubspot.tickets.................................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 14:44:31 | 2 of 13 START table model hubspot.engagements................................................................ [RUN]
�[32mnormalization�[0m - 2021-11-16 14:44:31 INFO () LineGobbler(voidCall):82 - 14:44:31 | 3 of 13 START table model hubspot.owners..................................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:44:34 INFO () LineGobbler(voidCall):82 - 14:44:34 | 3 of 13 OK created table model hubspot.owners................................................................ [�[32mCREATE TABLE (114.0 rows, 34.2 KB processed)�[0m in 2.23s]
�[32mnormalization�[0m - 2021-11-16 14:44:34 INFO () LineGobbler(voidCall):82 - 14:44:34 | 4 of 13 START table model hubspot.owners_teams............................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:44:36 INFO () LineGobbler(voidCall):82 - 14:44:36 | 4 of 13 OK created table model hubspot.owners_teams.......................................................... [�[32mCREATE TABLE (126.0 rows, 14.1 KB processed)�[0m in 2.19s]
�[32mnormalization�[0m - 2021-11-16 14:44:36 INFO () LineGobbler(voidCall):82 - 14:44:36 | 1 of 13 OK created table model hubspot.tickets............................................................... [�[32mCREATE TABLE (6.1k rows, 53.9 MB processed)�[0m in 4.73s]
�[32mnormalization�[0m - 2021-11-16 14:44:39 INFO () LineGobbler(voidCall):82 - 14:44:39 | 5 of 13 START table model hubspot.tickets_properties......................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:46:56 INFO () LineGobbler(voidCall):82 - 14:46:56 | 5 of 13 OK created table model hubspot.tickets_properties.................................................... [�[32mCREATE TABLE (6.1k rows, 53.3 MB processed)�[0m in 137.12s]
�[32mnormalization�[0m - 2021-11-16 14:47:40 INFO () LineGobbler(voidCall):82 - 14:47:40 | 2 of 13 OK created table model hubspot.engagements........................................................... [�[32mCREATE TABLE (502.1k rows, 5.7 GB processed)�[0m in 188.85s]
�[32mnormalization�[0m - 2021-11-16 14:47:41 INFO () LineGobbler(voidCall):82 - 14:47:41 | 6 of 13 START table model hubspot.engagements_associations................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:47:41 INFO () LineGobbler(voidCall):82 - 14:47:41 | 7 of 13 START table model hubspot.engagements_attachments.................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:47:41 INFO () LineGobbler(voidCall):82 - 14:47:41 | 8 of 13 START table model hubspot.engagements_metadata....................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:47:42 INFO () LineGobbler(voidCall):82 - 14:47:42 | 9 of 13 START table model hubspot.engagements_properties..................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:47:44 INFO () LineGobbler(voidCall):82 - 14:47:44 | 9 of 13 OK created table model hubspot.engagements_properties................................................ [�[32mCREATE TABLE (0.0 rows, 38.3 MB processed)�[0m in 2.27s]
�[32mnormalization�[0m - 2021-11-16 14:47:44 INFO () LineGobbler(voidCall):82 - 14:47:44 | 7 of 13 OK created table model hubspot.engagements_attachments............................................... [�[32mCREATE TABLE (149.5k rows, 41.1 MB processed)�[0m in 3.61s]
�[32mnormalization�[0m - 2021-11-16 14:47:50 INFO () LineGobbler(voidCall):82 - 14:47:50 | 6 of 13 OK created table model hubspot.engagements_associations.............................................. [�[32mCREATE TABLE (502.1k rows, 111.6 MB processed)�[0m in 9.33s]
�[32mnormalization�[0m - 2021-11-16 14:51:13 INFO () LineGobbler(voidCall):82 - 14:51:13 | 8 of 13 OK created table model hubspot.engagements_metadata.................................................. [�[32mCREATE TABLE (502.1k rows, 3.9 GB processed)�[0m in 211.86s]
�[32mnormalization�[0m - 2021-11-16 14:51:13 INFO () LineGobbler(voidCall):82 - 14:51:13 | 10 of 13 START table model hubspot.engagements_metadata_bcc.................................................. [RUN]
�[32mnormalization�[0m - 2021-11-16 14:51:13 INFO () LineGobbler(voidCall):82 - 14:51:13 | 12 of 13 START table model hubspot.engagements_metadata_from................................................. [RUN]
�[32mnormalization�[0m - 2021-11-16 14:51:13 INFO () LineGobbler(voidCall):82 - 14:51:13 | 11 of 13 START table model hubspot.engagements_metadata_to................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:51:13 INFO () LineGobbler(voidCall):82 - 14:51:13 | 13 of 13 START table model hubspot.engagements_metadata_cc................................................... [RUN]
�[32mnormalization�[0m - 2021-11-16 14:51:16 INFO () LineGobbler(voidCall):82 - 14:51:16 | 13 of 13 OK created table model hubspot.engagements_metadata_cc.............................................. [�[32mCREATE TABLE (26.0k rows, 41.0 MB processed)�[0m in 2.61s]
�[32mnormalization�[0m - 2021-11-16 14:51:16 INFO () LineGobbler(voidCall):82 - 14:51:16 | 10 of 13 OK created table model hubspot.engagements_metadata_bcc............................................. [�[32mCREATE TABLE (0.0 rows, 38.3 MB processed)�[0m in 2.68s]
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 14:51:18 | 11 of 13 OK created table model hubspot.engagements_metadata_to.............................................. [�[32mCREATE TABLE (279.5k rows, 64.5 MB processed)�[0m in 5.03s]
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 14:51:18 | 12 of 13 OK created table model hubspot.engagements_metadata_from............................................ [�[32mCREATE TABLE (249.8k rows, 62.0 MB processed)�[0m in 5.47s]
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 14:51:18 | 
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 14:51:18 | Finished running 13 table models in 407.70s.
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - �[32mCompleted successfully�[0m
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-16 14:51:18 INFO () LineGobbler(voidCall):82 - Done. PASS=13 WARN=0 ERROR=0 SKIP=0 TOTAL=13
2021-11-16 14:51:19 INFO () DefaultNormalizationWorker(run):69 - Normalization executed in 6 minutes 55 seconds.
2021-11-16 14:51:19 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2021-11-16 14:51:19 INFO () SlackNotificationClient(notify):89 - Successful notification (200): ok

Steps to Reproduce

Set up HubSpot connection.
Retrieve tickets object.
find a ticket that has transitioned between statuses.
Query HubSpot API for the same ticket.
Compare results.

Are you willing to submit a PR?

Yes.

The text was updated successfully, but these errors were encountered:

ghost added the type/bug Something isn't working label Nov 17, 2021

octavia-squidington-iii added the community label Nov 17, 2021

alafanechere added the area/connectors Connector related issues label Nov 17, 2021

grubberr self-assigned this Nov 23, 2021

grubberr linked a pull request Nov 23, 2021 that will close this issue

🐛 Source Hubspot: unset 'hs_time_in_*' properties #8216

Merged

16 tasks

grubberr closed this as completed in #8216 Nov 26, 2021

grubberr mentioned this issue Dec 24, 2021

Source Hubspot: Some incremental CRM objects and engagements #8887

Merged

40 tasks

igrankova added connectors/sources-api connectors/source/hubspot labels Jan 10, 2022

karinakuz added connectors/destination/bigquery connectors/destinations-api labels Jan 12, 2022

sherifnada moved this to Done in GL Roadmap Jan 12, 2022

sherifnada added this to GL Roadmap Jan 12, 2022

karinakuz added connectors/destinations-warehouse and removed connectors/destinations-api labels Jan 13, 2022

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Missing values in HubSpot tickets object #8055

Missing values in HubSpot tickets object #8055

ghost commented Nov 17, 2021 •

edited by alafanechere

Loading

Missing values in HubSpot tickets object #8055

Missing values in HubSpot tickets object #8055

Comments

ghost commented Nov 17, 2021 • edited by alafanechere Loading

Environment

Current Behavior

Expected Behavior

Logs

Steps to Reproduce

Are you willing to submit a PR?

ghost commented Nov 17, 2021 •

edited by alafanechere

Loading