2022-07-29 08:33:36 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: is not defined in the schema and the schema does not allow additional properties, $.username: is not defined in the schema and the schema does not allow additional properties, $.authorization: must be a constant value none 2022-07-29 08:33:36 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2022-07-29 08:33:36 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/71/0/logs.log 2022-07-29 08:33:36 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-07-29 08:33:37 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false' 2022-07-29 08:33:37 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-intercom:0.1.24 exists... 2022-07-29 08:33:37 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-intercom:0.1.24 was found locally. 2022-07-29 08:33:37 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 71 2022-07-29 08:33:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/71/0 --log-driver none --name source-intercom-check-71-0-ohbxm --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-intercom:0.1.24 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=71 --cpus=1.5 airbyte/source-intercom:0.1.24 check --config source_config.json 2022-07-29 08:33:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded 2022-07-29 08:33:41 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-07-29 08:33:41 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/71/0/logs.log 2022-07-29 08:33:41 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-07-29 08:33:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false' 2022-07-29 08:33:41 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mongodb:0.1.5 exists... 2022-07-29 08:33:41 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mongodb:0.1.5 was found locally. 2022-07-29 08:33:41 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 71 2022-07-29 08:33:41 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/71/0 --log-driver none --name destination-mongodb-check-71-0-gxkxk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mongodb:0.1.5 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=71 --cpus=1.5 airbyte/destination-mongodb:0.1.5 check --config source_config.json 2022-07-29 08:33:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:46 INFO i.a.i.d.m.MongodbDestination(main):64 - starting destination: class io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:46 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-29 08:33:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:46 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:46 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2022-07-29 08:33:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:46 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[*****.eu-west-1.docdb.amazonaws.com:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:33:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:47 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=*****.eu-west-1.docdb.amazonaws.com:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=61771412, setName='rs0', canonicalAddress=***************.eu-west-1.docdb.amazonaws.com:27017, hosts=[**************.eu-west-1.docdb.amazonaws.com:27017], passives=[], arbiters=[], primary='*************.eu-west-1.docdb.amazonaws.com:27017', tagSet=TagSet{[]}, electionId=7fffffff000000000000000b, setVersion=null, topologyVersion=null, lastWriteDate=Fri Jul 29 08:33:47 UTC 2022, lastUpdateTimeNanos=7678022753456} 2022-07-29 08:33:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:48 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:33:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:48 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-29 08:33:48 INFO i.a.i.d.m.MongodbDestination(main):66 - completed destination: class io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:48 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-07-29 08:33:49 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/71/0/logs.log 2022-07-29 08:33:49 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-07-29 08:33:49 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false' 2022-07-29 08:33:49 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 71 attempt id: 0 2022-07-29 08:33:49 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {null.companies=full_refresh - overwrite, null.contacts=full_refresh - overwrite} 2022-07-29 08:33:49 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-29 08:33:49 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false' 2022-07-29 08:33:49 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mongodb:0.1.5 exists... 2022-07-29 08:33:49 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mongodb:0.1.5 was found locally. 2022-07-29 08:33:49 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 71 2022-07-29 08:33:49 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/71/0 --log-driver none --name destination-mongodb-write-71-0-ltvdd --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mongodb:0.1.5 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=71 --cpus=1.5 airbyte/destination-mongodb:0.1.5 write --config destination_config.json --catalog destination_catalog.json 2022-07-29 08:33:49 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false' 2022-07-29 08:33:49 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-intercom:0.1.24 exists... 2022-07-29 08:33:49 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 71 2022-07-29 08:33:49 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/71/0 --log-driver none --name source-intercom-read-71-0-ltggq --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-intercom:0.1.24 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=71 --cpus=1.5 airbyte/source-intercom:0.1.24 read --config source_config.json --catalog source_catalog.json 2022-07-29 08:33:49 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-intercom:0.1.24 was found locally. 2022-07-29 08:33:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2022-07-29 08:33:49 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2022-07-29 08:33:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2022-07-29 08:33:56 source > Starting syncing SourceIntercom 2022-07-29 08:33:56 source > Using start_date: 1262304000.0 2022-07-29 08:33:56 source > Syncing stream: companies 2022-07-29 08:33:56 destination > 2022-07-29 08:33:56 INFO i.a.i.d.m.MongodbDestination(main):64 - starting destination: class io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:57 destination > 2022-07-29 08:33:57 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-07-29 08:33:57 destination > 2022-07-29 08:33:57 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.mongodb.MongodbDestination 2022-07-29 08:33:57 destination > 2022-07-29 08:33:57 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE 2022-07-29 08:33:57 destination > 2022-07-29 08:33:57 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-07-29 08:33:58 destination > 2022-07-29 08:33:58 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:58 destination > 2022-07-29 08:33:58 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:58 destination > 2022-07-29 08:33:58 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-29 08:33:59 destination > 2022-07-29 08:33:59 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[*****.eu-west-1.docdb.amazonaws.com:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2022-07-29 08:33:59 destination > 2022-07-29 08:33:59 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2022-07-29 08:33:59 destination > 2022-07-29 08:33:59 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:33:59 destination > 2022-07-29 08:33:59 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:33:59 destination > 2022-07-29 08:33:59 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=*****.eu-west-1.docdb.amazonaws.com:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=53596086, setName='rs0', canonicalAddress=**********.eu-west-1.docdb.amazonaws.com:27017, hosts=[**********.eu-west-1.docdb.amazonaws.com:27017], passives=[], arbiters=[], primary='**********.eu-west-1.docdb.amazonaws.com:27017', tagSet=TagSet{[]}, electionId=7fffffff000000000000000b, setVersion=null, topologyVersion=null, lastWriteDate=Fri Jul 29 08:33:59 UTC 2022, lastUpdateTimeNanos=7689560513213} 2022-07-29 08:34:00 destination > 2022-07-29 08:34:00 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3}] to *****.eu-west-1.docdb.amazonaws.com:27017 2022-07-29 08:34:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (1 MB) 2022-07-29 08:34:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (3 MB) 2022-07-29 08:34:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (4 MB) 2022-07-29 08:34:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (6 MB) 2022-07-29 08:34:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (8 MB) 2022-07-29 08:34:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (10 MB) 2022-07-29 08:34:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (12 MB) 2022-07-29 08:35:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (14 MB) 2022-07-29 08:35:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (16 MB) 2022-07-29 08:35:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (18 MB) 2022-07-29 08:35:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (20 MB) 2022-07-29 08:35:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (22 MB) 2022-07-29 08:35:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (23 MB) 2022-07-29 08:35:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (25 MB) 2022-07-29 08:35:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (27 MB) 2022-07-29 08:35:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (29 MB) 2022-07-29 08:36:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (31 MB) 2022-07-29 08:36:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (33 MB) 2022-07-29 08:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (35 MB) 2022-07-29 08:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (36 MB) 2022-07-29 08:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (38 MB) 2022-07-29 08:36:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (40 MB) 2022-07-29 08:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (42 MB) 2022-07-29 08:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (44 MB) 2022-07-29 08:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (46 MB) 2022-07-29 08:37:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (48 MB) 2022-07-29 08:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (50 MB) 2022-07-29 08:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (52 MB) 2022-07-29 08:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (53 MB) 2022-07-29 08:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (55 MB) 2022-07-29 08:37:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (57 MB) 2022-07-29 08:37:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (59 MB) 2022-07-29 08:37:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (61 MB) 2022-07-29 08:37:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (63 MB) 2022-07-29 08:38:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (64 MB) 2022-07-29 08:38:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (66 MB) 2022-07-29 08:38:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (68 MB) 2022-07-29 08:38:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (70 MB) 2022-07-29 08:38:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (72 MB) 2022-07-29 08:38:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (74 MB) 2022-07-29 08:38:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (75 MB) 2022-07-29 08:38:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (77 MB) 2022-07-29 08:38:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 43000 (79 MB) 2022-07-29 08:39:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 44000 (81 MB) 2022-07-29 08:39:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 45000 (82 MB) 2022-07-29 08:39:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 46000 (84 MB) 2022-07-29 08:39:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 47000 (86 MB) 2022-07-29 08:39:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 48000 (88 MB) 2022-07-29 08:39:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 49000 (90 MB) 2022-07-29 08:39:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 50000 (92 MB) 2022-07-29 08:39:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 51000 (93 MB) 2022-07-29 08:39:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 52000 (95 MB) 2022-07-29 08:40:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 53000 (97 MB) 2022-07-29 08:40:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 54000 (99 MB) 2022-07-29 08:40:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 55000 (101 MB) 2022-07-29 08:40:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 56000 (103 MB) 2022-07-29 08:40:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 57000 (104 MB) 2022-07-29 08:40:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 58000 (106 MB) 2022-07-29 08:40:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 59000 (108 MB) 2022-07-29 08:40:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 60000 (110 MB) 2022-07-29 08:40:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 61000 (112 MB) 2022-07-29 08:41:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 62000 (114 MB) 2022-07-29 08:41:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 63000 (116 MB) 2022-07-29 08:41:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 64000 (118 MB) 2022-07-29 08:41:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 65000 (120 MB) 2022-07-29 08:41:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 66000 (122 MB) 2022-07-29 08:41:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 67000 (124 MB) 2022-07-29 08:41:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 68000 (126 MB) 2022-07-29 08:41:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 69000 (128 MB) 2022-07-29 08:41:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 70000 (129 MB) 2022-07-29 08:42:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 71000 (131 MB) 2022-07-29 08:42:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 72000 (133 MB) 2022-07-29 08:42:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 73000 (135 MB) 2022-07-29 08:42:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 74000 (136 MB) 2022-07-29 08:42:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 75000 (138 MB) 2022-07-29 08:42:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 76000 (139 MB) 2022-07-29 08:42:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 77000 (141 MB) 2022-07-29 08:42:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 78000 (143 MB) 2022-07-29 08:42:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 79000 (145 MB) 2022-07-29 08:43:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 80000 (147 MB) 2022-07-29 08:43:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 81000 (149 MB) 2022-07-29 08:43:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 82000 (150 MB) 2022-07-29 08:43:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 83000 (152 MB) 2022-07-29 08:43:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 84000 (154 MB) 2022-07-29 08:43:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 85000 (156 MB) 2022-07-29 08:43:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 86000 (158 MB) 2022-07-29 08:43:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 87000 (160 MB) 2022-07-29 08:43:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 88000 (162 MB) 2022-07-29 08:44:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 89000 (165 MB) 2022-07-29 08:44:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 90000 (167 MB) 2022-07-29 08:44:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 91000 (169 MB) 2022-07-29 08:44:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 92000 (171 MB) 2022-07-29 08:44:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 93000 (173 MB) 2022-07-29 08:44:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 94000 (175 MB) 2022-07-29 08:44:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 95000 (177 MB) 2022-07-29 08:44:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 96000 (179 MB) 2022-07-29 08:45:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 97000 (181 MB) 2022-07-29 08:45:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 98000 (184 MB) 2022-07-29 08:45:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 99000 (186 MB) 2022-07-29 08:45:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 100000 (188 MB) 2022-07-29 08:45:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 101000 (190 MB) 2022-07-29 08:45:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 102000 (192 MB) 2022-07-29 08:45:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 103000 (194 MB) 2022-07-29 08:45:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 104000 (196 MB) 2022-07-29 08:46:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 105000 (198 MB) 2022-07-29 08:46:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 106000 (200 MB) 2022-07-29 08:46:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 107000 (202 MB) 2022-07-29 08:46:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 108000 (204 MB) 2022-07-29 08:46:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 109000 (206 MB) 2022-07-29 08:46:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 110000 (208 MB) 2022-07-29 08:46:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 111000 (210 MB) 2022-07-29 08:47:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 112000 (212 MB) 2022-07-29 08:47:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 113000 (215 MB) 2022-07-29 08:47:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 114000 (217 MB) 2022-07-29 08:47:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 115000 (220 MB) 2022-07-29 08:47:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 116000 (222 MB) 2022-07-29 08:48:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 117000 (225 MB) 2022-07-29 08:48:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 118000 (227 MB) 2022-07-29 08:48:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 119000 (230 MB) 2022-07-29 08:48:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 120000 (232 MB) 2022-07-29 08:48:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 121000 (235 MB) 2022-07-29 08:48:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 122000 (237 MB) 2022-07-29 08:49:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 123000 (240 MB) 2022-07-29 08:49:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 124000 (242 MB) 2022-07-29 08:49:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 125000 (245 MB) 2022-07-29 08:49:30 source > Read 125638 records from companies stream 2022-07-29 08:49:30 source > Finished syncing companies 2022-07-29 08:49:30 source > SourceIntercom runtimes: Syncing stream companies 0:15:33.981068 2022-07-29 08:49:30 source > Syncing stream: contacts 2022-07-29 08:49:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 126000 (247 MB) 2022-07-29 08:49:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 127000 (248 MB) 2022-07-29 08:49:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 128000 (249 MB) 2022-07-29 08:50:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 129000 (251 MB) 2022-07-29 08:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 130000 (252 MB) 2022-07-29 08:50:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 131000 (254 MB) 2022-07-29 08:51:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 132000 (255 MB) 2022-07-29 08:51:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 133000 (257 MB) 2022-07-29 08:52:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 134000 (258 MB) 2022-07-29 08:52:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 135000 (260 MB) 2022-07-29 08:53:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 136000 (262 MB) 2022-07-29 08:54:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 137000 (264 MB) 2022-07-29 08:55:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 138000 (266 MB) 2022-07-29 08:56:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 139000 (268 MB) 2022-07-29 08:56:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 140000 (270 MB) 2022-07-29 08:58:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 141000 (272 MB) 2022-07-29 08:59:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 142000 (274 MB) 2022-07-29 09:00:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 143000 (276 MB) 2022-07-29 09:02:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 144000 (278 MB) 2022-07-29 09:03:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 145000 (280 MB) 2022-07-29 09:05:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 146000 (282 MB) 2022-07-29 09:06:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 147000 (285 MB) 2022-07-29 09:08:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 148000 (287 MB) 2022-07-29 09:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 149000 (289 MB) 2022-07-29 09:13:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 150000 (291 MB) 2022-07-29 09:16:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 151000 (293 MB) 2022-07-29 09:18:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 152000 (296 MB) 2022-07-29 09:21:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 153000 (298 MB) 2022-07-29 09:25:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 154000 (300 MB) 2022-07-29 09:27:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 155000 (302 MB) 2022-07-29 09:31:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 156000 (305 MB) 2022-07-29 09:35:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 157000 (307 MB) 2022-07-29 09:38:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 158000 (309 MB) 2022-07-29 09:42:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 159000 (311 MB) 2022-07-29 09:46:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 160000 (314 MB) 2022-07-29 09:50:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 161000 (316 MB) 2022-07-29 09:55:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 162000 (318 MB) 2022-07-29 10:00:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 163000 (320 MB) 2022-07-29 10:03:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 164000 (323 MB) 2022-07-29 10:08:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 165000 (325 MB) 2022-07-29 10:13:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 166000 (327 MB) 2022-07-29 10:17:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 167000 (329 MB) 2022-07-29 10:22:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 168000 (332 MB) 2022-07-29 10:28:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 169000 (334 MB) 2022-07-29 10:33:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 170000 (336 MB) 2022-07-29 10:39:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 171000 (338 MB) 2022-07-29 10:45:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 172000 (341 MB) 2022-07-29 10:50:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 173000 (343 MB) 2022-07-29 10:56:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 174000 (345 MB) 2022-07-29 11:02:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 175000 (347 MB) 2022-07-29 11:07:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 176000 (350 MB) 2022-07-29 11:14:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 177000 (352 MB) 2022-07-29 11:21:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 178000 (354 MB) 2022-07-29 11:26:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 179000 (356 MB) 2022-07-29 11:34:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 180000 (359 MB) 2022-07-29 11:41:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 181000 (361 MB) 2022-07-29 11:47:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 182000 (363 MB) 2022-07-29 11:55:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 183000 (365 MB) 2022-07-29 12:02:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 184000 (368 MB) 2022-07-29 12:09:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 185000 (370 MB) 2022-07-29 12:16:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 186000 (372 MB) 2022-07-29 12:25:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 187000 (374 MB) 2022-07-29 12:31:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 188000 (377 MB) 2022-07-29 12:40:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 189000 (379 MB) 2022-07-29 12:47:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 190000 (381 MB) 2022-07-29 12:55:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 191000 (383 MB) 2022-07-29 13:04:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 192000 (386 MB) 2022-07-29 13:12:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 193000 (388 MB) 2022-07-29 13:20:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 194000 (390 MB) 2022-07-29 13:29:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 195000 (393 MB) 2022-07-29 13:38:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 196000 (395 MB) 2022-07-29 13:46:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 197000 (397 MB) 2022-07-29 13:56:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 198000 (399 MB) 2022-07-29 14:06:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 199000 (401 MB)