2022-04-07 00:11:44 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-07 00:11:44 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/491/2/logs.log
2022-04-07 00:11:44 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-07 00:11:44 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 491 attempt id: 2
2022-04-07 00:11:44 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {admin.offer_position_capable_producers=full_refresh - overwrite, admin.provider_calc_result=full_refresh - overwrite, admin.vw_nestedPlates=full_refresh - overwrite}
2022-04-07 00:11:44 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-07 00:11:44 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:1.0.2 exists...
2022-04-07 00:11:44 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 491
2022-04-07 00:11:44 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/491/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.0.2 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=491 airbyte/destination-bigquery:1.0.2 write --config destination_config.json --catalog destination_catalog.json
2022-04-07 00:11:44 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery:1.0.2 was found locally.
2022-04-07 00:11:44 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.13 exists...
2022-04-07 00:11:45 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.13 was found locally.
2022-04-07 00:11:45 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 491
2022-04-07 00:11:45 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/491/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.13 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=491 airbyte/source-mongodb-v2:0.1.13 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-07 00:11:45 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-07 00:11:45 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-07 00:11:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-07 00:11:47 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-07 00:11:47 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 00:11:47 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 00:11:47 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-07 00:11:47 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-07 00:11:50 source > 2022-04-07 00:11:50 INFO i.a.i.s.m.MongoDbSource(main):64 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 00:11:51 destination > 2022-04-07 00:11:51 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 00:11:52 source > 2022-04-07 00:11:52 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-04-07 00:11:52 source > 2022-04-07 00:11:52 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 7d747b40686a44f1af2d93232f76f33f
2022-04-07 00:11:52 source > 2022-04-07 00:11:52 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource
2022-04-07 00:11:52 source > 2022-04-07 00:11:52 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
2022-04-07 00:11:52 source > 2022-04-07 00:11:52 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-04-07 00:11:52 destination > 2022-04-07 00:11:52 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='offer_position_capable_producers', namespace='admin'}, New Cursor Field: null. Resetting cursor value
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='provider_calc_result', namespace='admin'}, New Cursor Field: null. Resetting cursor value
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='vw_nestedPlates', namespace='admin'}, New Cursor Field: null. Resetting cursor value
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[127.0.0.1:27017], srvHost=lh-mongo-instance-prod.oflxb.mongodb.net, mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='lh-mongo-instance-prod-shard-0'}
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017 to client view of cluster
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017 to client view of cluster
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017 to client view of cluster
2022-04-07 00:11:53 source > 2022-04-07 00:11:53 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@5c41d037 from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:6, serverValue:13680}] to lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:5, serverValue:14971}] to lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:13799}] to lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:13800}] to lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:14972}] to lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:4, serverValue:13679}] to lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017
2022-04-07 00:11:55 destination > 2022-04-07 00:11:55 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_tmp_fky_offer_position_capable_producers}} created successfully
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=8, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=834095021, setName='lh-mongo-instance-prod-shard-0', canonicalAddress=lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, hosts=[lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017], passives=[], arbiters=[], primary='lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_CENTRAL_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=4, topologyVersion=null, lastWriteDate=Thu Apr 07 00:11:51 UTC 2022, lastUpdateTimeNanos=38845753045529}
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=8, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=850957019, setName='lh-mongo-instance-prod-shard-0', canonicalAddress=lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017, hosts=[lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017], passives=[], arbiters=[], primary='lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_CENTRAL_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=4, topologyVersion=null, lastWriteDate=Thu Apr 07 00:11:51 UTC 2022, lastUpdateTimeNanos=38845768552510}
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=8, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=849084753, setName='lh-mongo-instance-prod-shard-0', canonicalAddress=lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, hosts=[lh-mongo-instance-prod-shard-00-00.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017, lh-mongo-instance-prod-shard-00-02.oflxb.mongodb.net:27017], passives=[], arbiters=[], primary='lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_CENTRAL_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=7fffffff000000000000003a, setVersion=4, topologyVersion=null, lastWriteDate=Thu Apr 07 00:11:51 UTC 2022, lastUpdateTimeNanos=38845766611471}
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max election id to 7fffffff000000000000003a from replica set primary lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max set version to 4 from replica set primary lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:55 source > 2022-04-07 00:11:55 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:56 destination > 2022-04-07 00:11:56 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD
2022-04-07 00:11:56 source > 2022-04-07 00:11:56 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:7, serverValue:14973}] to lh-mongo-instance-prod-shard-00-01.oflxb.mongodb.net:27017
2022-04-07 00:11:56 destination > 2022-04-07 00:11:56 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_tmp_csm_provider_calc_result}} created successfully
2022-04-07 00:11:57 destination > 2022-04-07 00:11:57 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):284 - Selected loading method is set to: STANDARD
2022-04-07 00:11:58 destination > 2022-04-07 00:11:58 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):124 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_tmp_dbg_vw_nestedPlates}} created successfully
2022-04-07 00:12:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (1 MB)
2022-04-07 00:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (2 MB)
2022-04-07 00:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (3 MB)
2022-04-07 00:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (4 MB)
2022-04-07 00:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (5 MB)
2022-04-07 00:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (6 MB)
2022-04-07 00:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (8 MB)
2022-04-07 00:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (9 MB)
2022-04-07 00:12:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (10 MB)
2022-04-07 00:12:59 source > 2022-04-07 00:12:58 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream offer_position_capable_producers. Records read: 10000
2022-04-07 00:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (11 MB)
2022-04-07 00:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (12 MB)
2022-04-07 00:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (13 MB)
2022-04-07 00:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (14 MB)
2022-04-07 00:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (15 MB)
2022-04-07 00:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (16 MB)
2022-04-07 00:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 16000 (18 MB)
2022-04-07 00:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 17000 (19 MB)
2022-04-07 00:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 18000 (20 MB)
2022-04-07 00:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 19000 (21 MB)
2022-04-07 00:13:08 source > 2022-04-07 00:13:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream offer_position_capable_producers. Records read: 20000
2022-04-07 00:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 20000 (22 MB)
2022-04-07 00:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 21000 (23 MB)
2022-04-07 00:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 22000 (24 MB)
2022-04-07 00:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 23000 (26 MB)
2022-04-07 00:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 24000 (27 MB)
2022-04-07 00:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 25000 (28 MB)
2022-04-07 00:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 26000 (29 MB)
2022-04-07 00:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 27000 (30 MB)
2022-04-07 00:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 28000 (31 MB)
2022-04-07 00:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 29000 (32 MB)
2022-04-07 00:13:15 source > 2022-04-07 00:13:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream offer_position_capable_producers. Records read: 30000
2022-04-07 00:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 30000 (34 MB)
2022-04-07 00:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 31000 (35 MB)
2022-04-07 00:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 32000 (36 MB)
2022-04-07 00:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 33000 (37 MB)
2022-04-07 00:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 34000 (38 MB)
2022-04-07 00:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 35000 (39 MB)
2022-04-07 00:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 36000 (41 MB)
2022-04-07 00:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 37000 (41 MB)
2022-04-07 00:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 38000 (42 MB)
2022-04-07 00:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 39000 (42 MB)
2022-04-07 00:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 40000 (43 MB)
2022-04-07 00:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 41000 (43 MB)
2022-04-07 00:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 42000 (43 MB)
2022-04-07 00:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 43000 (44 MB)
2022-04-07 00:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 44000 (44 MB)
2022-04-07 00:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 45000 (45 MB)
2022-04-07 00:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 46000 (45 MB)
2022-04-07 00:13:26 source > 2022-04-07 00:13:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 10000
2022-04-07 00:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 47000 (45 MB)
2022-04-07 00:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 48000 (46 MB)
2022-04-07 00:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 49000 (46 MB)
2022-04-07 00:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 50000 (47 MB)
2022-04-07 00:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 51000 (47 MB)
2022-04-07 00:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 52000 (47 MB)
2022-04-07 00:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 53000 (48 MB)
2022-04-07 00:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 54000 (48 MB)
2022-04-07 00:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 55000 (49 MB)
2022-04-07 00:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 56000 (49 MB)
2022-04-07 00:13:29 source > 2022-04-07 00:13:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 20000
2022-04-07 00:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 57000 (49 MB)
2022-04-07 00:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 58000 (50 MB)
2022-04-07 00:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 59000 (50 MB)
2022-04-07 00:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 60000 (51 MB)
2022-04-07 00:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 61000 (51 MB)
2022-04-07 00:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 62000 (51 MB)
2022-04-07 00:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 63000 (52 MB)
2022-04-07 00:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 64000 (52 MB)
2022-04-07 00:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 65000 (53 MB)
2022-04-07 00:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 66000 (53 MB)
2022-04-07 00:13:33 source > 2022-04-07 00:13:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 30000
2022-04-07 00:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 67000 (53 MB)
2022-04-07 00:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 68000 (54 MB)
2022-04-07 00:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 69000 (54 MB)
2022-04-07 00:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 70000 (55 MB)
2022-04-07 00:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 71000 (55 MB)
2022-04-07 00:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 72000 (55 MB)
2022-04-07 00:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 73000 (56 MB)
2022-04-07 00:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 74000 (56 MB)
2022-04-07 00:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 75000 (57 MB)
2022-04-07 00:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 76000 (57 MB)
2022-04-07 00:13:38 source > 2022-04-07 00:13:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 40000
2022-04-07 00:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 77000 (57 MB)
2022-04-07 00:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 78000 (58 MB)
2022-04-07 00:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 79000 (58 MB)
2022-04-07 00:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 80000 (59 MB)
2022-04-07 00:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 81000 (59 MB)
2022-04-07 00:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 82000 (59 MB)
2022-04-07 00:13:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 83000 (60 MB)
2022-04-07 00:13:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 84000 (60 MB)
2022-04-07 00:13:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 85000 (61 MB)
2022-04-07 00:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 86000 (61 MB)
2022-04-07 00:13:45 source > 2022-04-07 00:13:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 50000
2022-04-07 00:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 87000 (62 MB)
2022-04-07 00:13:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 88000 (62 MB)
2022-04-07 00:13:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 89000 (63 MB)
2022-04-07 00:13:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 90000 (63 MB)
2022-04-07 00:13:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 91000 (64 MB)
2022-04-07 00:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 92000 (64 MB)
2022-04-07 00:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 93000 (65 MB)
2022-04-07 00:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 94000 (65 MB)
2022-04-07 00:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 95000 (65 MB)
2022-04-07 00:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 96000 (66 MB)
2022-04-07 00:13:51 source > 2022-04-07 00:13:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 60000
2022-04-07 00:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 97000 (66 MB)
2022-04-07 00:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 98000 (67 MB)
2022-04-07 00:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 99000 (67 MB)
2022-04-07 00:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 100000 (67 MB)
2022-04-07 00:13:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 101000 (68 MB)
2022-04-07 00:13:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 102000 (68 MB)
2022-04-07 00:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 103000 (69 MB)
2022-04-07 00:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 104000 (69 MB)
2022-04-07 00:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 105000 (69 MB)
2022-04-07 00:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 106000 (70 MB)
2022-04-07 00:13:54 source > 2022-04-07 00:13:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 70000
2022-04-07 00:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 107000 (70 MB)
2022-04-07 00:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 108000 (71 MB)
2022-04-07 00:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 109000 (71 MB)
2022-04-07 00:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 110000 (71 MB)
2022-04-07 00:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 111000 (72 MB)
2022-04-07 00:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 112000 (72 MB)
2022-04-07 00:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 113000 (73 MB)
2022-04-07 00:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 114000 (73 MB)
2022-04-07 00:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 115000 (73 MB)
2022-04-07 00:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 116000 (74 MB)
2022-04-07 00:13:58 source > 2022-04-07 00:13:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 80000
2022-04-07 00:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 117000 (74 MB)
2022-04-07 00:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 118000 (75 MB)
2022-04-07 00:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 119000 (75 MB)
2022-04-07 00:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 120000 (75 MB)
2022-04-07 00:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 121000 (76 MB)
2022-04-07 00:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 122000 (76 MB)
2022-04-07 00:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 123000 (77 MB)
2022-04-07 00:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 124000 (77 MB)
2022-04-07 00:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 125000 (77 MB)
2022-04-07 00:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 126000 (78 MB)
2022-04-07 00:14:01 source > 2022-04-07 00:14:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 90000
2022-04-07 00:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 127000 (78 MB)
2022-04-07 00:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 128000 (79 MB)
2022-04-07 00:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 129000 (79 MB)
2022-04-07 00:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 130000 (79 MB)
2022-04-07 00:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 131000 (80 MB)
2022-04-07 00:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 132000 (80 MB)
2022-04-07 00:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 133000 (81 MB)
2022-04-07 00:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 134000 (81 MB)
2022-04-07 00:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 135000 (81 MB)
2022-04-07 00:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 136000 (82 MB)
2022-04-07 00:14:05 source > 2022-04-07 00:14:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 100000
2022-04-07 00:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 137000 (82 MB)
2022-04-07 00:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 138000 (83 MB)
2022-04-07 00:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 139000 (83 MB)
2022-04-07 00:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 140000 (84 MB)
2022-04-07 00:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 141000 (84 MB)
2022-04-07 00:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 142000 (84 MB)
2022-04-07 00:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 143000 (85 MB)
2022-04-07 00:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 144000 (85 MB)
2022-04-07 00:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 145000 (86 MB)
2022-04-07 00:14:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 146000 (86 MB)
2022-04-07 00:14:11 source > 2022-04-07 00:14:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 110000
2022-04-07 00:14:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 147000 (87 MB)
2022-04-07 00:14:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 148000 (87 MB)
2022-04-07 00:14:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 149000 (88 MB)
2022-04-07 00:14:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 150000 (88 MB)
2022-04-07 00:14:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 151000 (89 MB)
2022-04-07 00:14:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 152000 (89 MB)
2022-04-07 00:14:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 153000 (89 MB)
2022-04-07 00:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 154000 (90 MB)
2022-04-07 00:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 155000 (91 MB)
2022-04-07 00:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 156000 (91 MB)
2022-04-07 00:14:16 source > 2022-04-07 00:14:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 120000
2022-04-07 00:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 157000 (92 MB)
2022-04-07 00:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 158000 (92 MB)
2022-04-07 00:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 159000 (92 MB)
2022-04-07 00:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 160000 (93 MB)
2022-04-07 00:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 161000 (93 MB)
2022-04-07 00:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 162000 (94 MB)
2022-04-07 00:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 163000 (94 MB)
2022-04-07 00:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 164000 (95 MB)
2022-04-07 00:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 165000 (95 MB)
2022-04-07 00:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 166000 (96 MB)
2022-04-07 00:14:20 source > 2022-04-07 00:14:19 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 130000
2022-04-07 00:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 167000 (96 MB)
2022-04-07 00:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 168000 (97 MB)
2022-04-07 00:14:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 169000 (97 MB)
2022-04-07 00:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 170000 (98 MB)
2022-04-07 00:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 171000 (98 MB)
2022-04-07 00:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 172000 (99 MB)
2022-04-07 00:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 173000 (99 MB)
2022-04-07 00:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 174000 (100 MB)
2022-04-07 00:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 175000 (100 MB)
2022-04-07 00:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 176000 (101 MB)
2022-04-07 00:14:24 source > 2022-04-07 00:14:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 140000
2022-04-07 00:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 177000 (101 MB)
2022-04-07 00:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 178000 (102 MB)
2022-04-07 00:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 179000 (102 MB)
2022-04-07 00:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 180000 (103 MB)
2022-04-07 00:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 181000 (103 MB)
2022-04-07 00:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 182000 (104 MB)
2022-04-07 00:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 183000 (105 MB)
2022-04-07 00:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 184000 (105 MB)
2022-04-07 00:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 185000 (106 MB)
2022-04-07 00:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 186000 (106 MB)
2022-04-07 00:14:28 source > 2022-04-07 00:14:27 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 150000
2022-04-07 00:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 187000 (107 MB)
2022-04-07 00:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 188000 (107 MB)
2022-04-07 00:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 189000 (108 MB)
2022-04-07 00:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 190000 (108 MB)
2022-04-07 00:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 191000 (109 MB)
2022-04-07 00:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 192000 (109 MB)
2022-04-07 00:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 193000 (110 MB)
2022-04-07 00:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 194000 (110 MB)
2022-04-07 00:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 195000 (111 MB)
2022-04-07 00:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 196000 (111 MB)
2022-04-07 00:14:34 source > 2022-04-07 00:14:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 160000
2022-04-07 00:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 197000 (112 MB)
2022-04-07 00:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 198000 (112 MB)
2022-04-07 00:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 199000 (113 MB)
2022-04-07 00:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 200000 (113 MB)
2022-04-07 00:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 201000 (114 MB)
2022-04-07 00:14:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 202000 (114 MB)
2022-04-07 00:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 203000 (115 MB)
2022-04-07 00:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 204000 (115 MB)
2022-04-07 00:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 205000 (116 MB)
2022-04-07 00:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 206000 (116 MB)
2022-04-07 00:14:40 source > 2022-04-07 00:14:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 170000
2022-04-07 00:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 207000 (117 MB)
2022-04-07 00:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 208000 (117 MB)
2022-04-07 00:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 209000 (118 MB)
2022-04-07 00:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 210000 (118 MB)
2022-04-07 00:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 211000 (119 MB)
2022-04-07 00:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 212000 (119 MB)
2022-04-07 00:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 213000 (120 MB)
2022-04-07 00:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 214000 (120 MB)
2022-04-07 00:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 215000 (120 MB)
2022-04-07 00:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 216000 (121 MB)
2022-04-07 00:14:44 source > 2022-04-07 00:14:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 180000
2022-04-07 00:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 217000 (122 MB)
2022-04-07 00:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 218000 (122 MB)
2022-04-07 00:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 219000 (122 MB)
2022-04-07 00:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 220000 (123 MB)
2022-04-07 00:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 221000 (123 MB)
2022-04-07 00:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 222000 (124 MB)
2022-04-07 00:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 223000 (124 MB)
2022-04-07 00:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 224000 (125 MB)
2022-04-07 00:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 225000 (125 MB)
2022-04-07 00:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 226000 (126 MB)
2022-04-07 00:14:49 source > 2022-04-07 00:14:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 190000
2022-04-07 00:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 227000 (126 MB)
2022-04-07 00:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 228000 (127 MB)
2022-04-07 00:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 229000 (127 MB)
2022-04-07 00:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 230000 (128 MB)
2022-04-07 00:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 231000 (128 MB)
2022-04-07 00:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 232000 (129 MB)
2022-04-07 00:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 233000 (129 MB)
2022-04-07 00:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 234000 (130 MB)
2022-04-07 00:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 235000 (130 MB)
2022-04-07 00:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 236000 (131 MB)
2022-04-07 00:14:53 source > 2022-04-07 00:14:52 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 200000
2022-04-07 00:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 237000 (131 MB)
2022-04-07 00:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 238000 (132 MB)
2022-04-07 00:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 239000 (132 MB)
2022-04-07 00:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 240000 (133 MB)
2022-04-07 00:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 241000 (133 MB)
2022-04-07 00:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 242000 (134 MB)
2022-04-07 00:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 243000 (134 MB)
2022-04-07 00:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 244000 (135 MB)
2022-04-07 00:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 245000 (136 MB)
2022-04-07 00:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 246000 (136 MB)
2022-04-07 00:14:57 source > 2022-04-07 00:14:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 210000
2022-04-07 00:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 247000 (137 MB)
2022-04-07 00:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 248000 (137 MB)
2022-04-07 00:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 249000 (138 MB)
2022-04-07 00:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 250000 (138 MB)
2022-04-07 00:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 251000 (139 MB)
2022-04-07 00:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 252000 (140 MB)
2022-04-07 00:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 253000 (140 MB)
2022-04-07 00:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 254000 (141 MB)
2022-04-07 00:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 255000 (141 MB)
2022-04-07 00:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 256000 (142 MB)
2022-04-07 00:15:01 source > 2022-04-07 00:15:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 220000
2022-04-07 00:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 257000 (142 MB)
2022-04-07 00:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 258000 (143 MB)
2022-04-07 00:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 259000 (143 MB)
2022-04-07 00:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 260000 (144 MB)
2022-04-07 00:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 261000 (144 MB)
2022-04-07 00:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 262000 (145 MB)
2022-04-07 00:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 263000 (145 MB)
2022-04-07 00:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 264000 (146 MB)
2022-04-07 00:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 265000 (146 MB)
2022-04-07 00:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 266000 (147 MB)
2022-04-07 00:15:05 source > 2022-04-07 00:15:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 230000
2022-04-07 00:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 267000 (147 MB)
2022-04-07 00:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 268000 (148 MB)
2022-04-07 00:15:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 269000 (148 MB)
2022-04-07 00:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 270000 (149 MB)
2022-04-07 00:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 271000 (149 MB)
2022-04-07 00:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 272000 (150 MB)
2022-04-07 00:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 273000 (151 MB)
2022-04-07 00:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 274000 (151 MB)
2022-04-07 00:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 275000 (152 MB)
2022-04-07 00:15:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 276000 (152 MB)
2022-04-07 00:15:09 source > 2022-04-07 00:15:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 240000
2022-04-07 00:15:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 277000 (153 MB)
2022-04-07 00:15:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 278000 (153 MB)
2022-04-07 00:15:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 279000 (154 MB)
2022-04-07 00:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 280000 (154 MB)
2022-04-07 00:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 281000 (155 MB)
2022-04-07 00:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 282000 (155 MB)
2022-04-07 00:15:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 283000 (156 MB)
2022-04-07 00:15:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 284000 (156 MB)
2022-04-07 00:15:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 285000 (157 MB)
2022-04-07 00:15:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 286000 (157 MB)
2022-04-07 00:15:13 source > 2022-04-07 00:15:12 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 250000
2022-04-07 00:15:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 287000 (158 MB)
2022-04-07 00:15:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 288000 (158 MB)
2022-04-07 00:15:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 289000 (159 MB)
2022-04-07 00:15:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 290000 (159 MB)
2022-04-07 00:15:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 291000 (160 MB)
2022-04-07 00:15:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 292000 (160 MB)
2022-04-07 00:15:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 293000 (161 MB)
2022-04-07 00:15:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 294000 (161 MB)
2022-04-07 00:15:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 295000 (162 MB)
2022-04-07 00:15:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 296000 (162 MB)
2022-04-07 00:15:17 source > 2022-04-07 00:15:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 260000
2022-04-07 00:15:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 297000 (163 MB)
2022-04-07 00:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 298000 (163 MB)
2022-04-07 00:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 299000 (164 MB)
2022-04-07 00:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 300000 (165 MB)
2022-04-07 00:15:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 301000 (165 MB)
2022-04-07 00:15:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 302000 (166 MB)
2022-04-07 00:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 303000 (166 MB)
2022-04-07 00:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 304000 (167 MB)
2022-04-07 00:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 305000 (168 MB)
2022-04-07 00:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 306000 (168 MB)
2022-04-07 00:15:21 source > 2022-04-07 00:15:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 270000
2022-04-07 00:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 307000 (169 MB)
2022-04-07 00:15:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 308000 (169 MB)
2022-04-07 00:15:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 309000 (170 MB)
2022-04-07 00:15:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 310000 (170 MB)
2022-04-07 00:15:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 311000 (171 MB)
2022-04-07 00:15:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 312000 (171 MB)
2022-04-07 00:15:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 313000 (172 MB)
2022-04-07 00:15:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 314000 (172 MB)
2022-04-07 00:15:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 315000 (173 MB)
2022-04-07 00:15:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 316000 (173 MB)
2022-04-07 00:15:25 source > 2022-04-07 00:15:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 280000
2022-04-07 00:15:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 317000 (174 MB)
2022-04-07 00:15:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 318000 (174 MB)
2022-04-07 00:15:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 319000 (175 MB)
2022-04-07 00:15:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 320000 (175 MB)
2022-04-07 00:15:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 321000 (176 MB)
2022-04-07 00:15:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 322000 (176 MB)
2022-04-07 00:15:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 323000 (177 MB)
2022-04-07 00:15:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 324000 (177 MB)
2022-04-07 00:15:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 325000 (178 MB)
2022-04-07 00:15:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 326000 (178 MB)
2022-04-07 00:15:29 source > 2022-04-07 00:15:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 290000
2022-04-07 00:15:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 327000 (179 MB)
2022-04-07 00:15:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 328000 (179 MB)
2022-04-07 00:15:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 329000 (180 MB)
2022-04-07 00:15:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 330000 (180 MB)
2022-04-07 00:15:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 331000 (181 MB)
2022-04-07 00:15:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 332000 (181 MB)
2022-04-07 00:15:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 333000 (182 MB)
2022-04-07 00:15:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 334000 (182 MB)
2022-04-07 00:15:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 335000 (183 MB)
2022-04-07 00:15:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 336000 (183 MB)
2022-04-07 00:15:34 source > 2022-04-07 00:15:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 300000
2022-04-07 00:15:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 337000 (184 MB)
2022-04-07 00:15:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 338000 (184 MB)
2022-04-07 00:15:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 339000 (185 MB)
2022-04-07 00:15:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 340000 (185 MB)
2022-04-07 00:15:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 341000 (186 MB)
2022-04-07 00:15:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 342000 (186 MB)
2022-04-07 00:15:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 343000 (187 MB)
2022-04-07 00:15:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 344000 (188 MB)
2022-04-07 00:15:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 345000 (188 MB)
2022-04-07 00:15:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 346000 (188 MB)
2022-04-07 00:15:40 source > 2022-04-07 00:15:39 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 310000
2022-04-07 00:15:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 347000 (189 MB)
2022-04-07 00:15:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 348000 (189 MB)
2022-04-07 00:15:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 349000 (190 MB)
2022-04-07 00:15:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 350000 (190 MB)
2022-04-07 00:15:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 351000 (191 MB)
2022-04-07 00:15:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 352000 (191 MB)
2022-04-07 00:15:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 353000 (192 MB)
2022-04-07 00:15:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 354000 (192 MB)
2022-04-07 00:15:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 355000 (193 MB)
2022-04-07 00:15:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 356000 (193 MB)
2022-04-07 00:15:44 source > 2022-04-07 00:15:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 320000
2022-04-07 00:15:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 357000 (194 MB)
2022-04-07 00:15:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 358000 (194 MB)
2022-04-07 00:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 359000 (195 MB)
2022-04-07 00:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 360000 (195 MB)
2022-04-07 00:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 361000 (196 MB)
2022-04-07 00:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 362000 (197 MB)
2022-04-07 00:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 363000 (197 MB)
2022-04-07 00:15:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 364000 (198 MB)
2022-04-07 00:15:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 365000 (198 MB)
2022-04-07 00:15:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 366000 (199 MB)
2022-04-07 00:15:48 source > 2022-04-07 00:15:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 330000
2022-04-07 00:15:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 367000 (199 MB)
2022-04-07 00:15:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 368000 (200 MB)
2022-04-07 00:15:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 369000 (200 MB)
2022-04-07 00:15:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 370000 (201 MB)
2022-04-07 00:15:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 371000 (201 MB)
2022-04-07 00:15:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 372000 (202 MB)
2022-04-07 00:15:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 373000 (202 MB)
2022-04-07 00:15:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 374000 (203 MB)
2022-04-07 00:15:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 375000 (203 MB)
2022-04-07 00:15:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 376000 (204 MB)
2022-04-07 00:15:51 source > 2022-04-07 00:15:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 340000
2022-04-07 00:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 377000 (204 MB)
2022-04-07 00:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 378000 (205 MB)
2022-04-07 00:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 379000 (205 MB)
2022-04-07 00:15:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 380000 (206 MB)
2022-04-07 00:15:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 381000 (206 MB)
2022-04-07 00:15:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 382000 (207 MB)
2022-04-07 00:15:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 383000 (207 MB)
2022-04-07 00:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 384000 (208 MB)
2022-04-07 00:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 385000 (208 MB)
2022-04-07 00:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 386000 (209 MB)
2022-04-07 00:15:55 source > 2022-04-07 00:15:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 350000
2022-04-07 00:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 387000 (209 MB)
2022-04-07 00:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 388000 (210 MB)
2022-04-07 00:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 389000 (210 MB)
2022-04-07 00:15:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 390000 (211 MB)
2022-04-07 00:15:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 391000 (211 MB)
2022-04-07 00:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 392000 (212 MB)
2022-04-07 00:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 393000 (212 MB)
2022-04-07 00:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 394000 (213 MB)
2022-04-07 00:15:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 395000 (213 MB)
2022-04-07 00:15:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 396000 (214 MB)
2022-04-07 00:15:59 source > 2022-04-07 00:15:58 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 360000
2022-04-07 00:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 397000 (214 MB)
2022-04-07 00:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 398000 (215 MB)
2022-04-07 00:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 399000 (215 MB)
2022-04-07 00:16:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 400000 (216 MB)
2022-04-07 00:16:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 401000 (216 MB)
2022-04-07 00:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 402000 (217 MB)
2022-04-07 00:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 403000 (217 MB)
2022-04-07 00:16:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 404000 (218 MB)
2022-04-07 00:16:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 405000 (218 MB)
2022-04-07 00:16:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 406000 (219 MB)
2022-04-07 00:16:04 source > 2022-04-07 00:16:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 370000
2022-04-07 00:16:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 407000 (219 MB)
2022-04-07 00:16:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 408000 (220 MB)
2022-04-07 00:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 409000 (220 MB)
2022-04-07 00:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 410000 (221 MB)
2022-04-07 00:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 411000 (221 MB)
2022-04-07 00:16:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 412000 (222 MB)
2022-04-07 00:16:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 413000 (222 MB)
2022-04-07 00:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 414000 (223 MB)
2022-04-07 00:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 415000 (223 MB)
2022-04-07 00:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 416000 (224 MB)
2022-04-07 00:16:08 source > 2022-04-07 00:16:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 380000
2022-04-07 00:16:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 417000 (224 MB)
2022-04-07 00:16:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 418000 (225 MB)
2022-04-07 00:16:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 419000 (225 MB)
2022-04-07 00:16:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 420000 (226 MB)
2022-04-07 00:16:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 421000 (226 MB)
2022-04-07 00:16:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 422000 (227 MB)
2022-04-07 00:16:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 423000 (227 MB)
2022-04-07 00:16:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 424000 (228 MB)
2022-04-07 00:16:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 425000 (228 MB)
2022-04-07 00:16:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 426000 (229 MB)
2022-04-07 00:16:12 source > 2022-04-07 00:16:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 390000
2022-04-07 00:16:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 427000 (229 MB)
2022-04-07 00:16:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 428000 (230 MB)
2022-04-07 00:16:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 429000 (230 MB)
2022-04-07 00:16:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 430000 (231 MB)
2022-04-07 00:16:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 431000 (231 MB)
2022-04-07 00:16:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 432000 (232 MB)
2022-04-07 00:16:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 433000 (232 MB)
2022-04-07 00:16:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 434000 (233 MB)
2022-04-07 00:16:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 435000 (233 MB)
2022-04-07 00:16:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 436000 (234 MB)
2022-04-07 00:16:16 source > 2022-04-07 00:16:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 400000
2022-04-07 00:16:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 437000 (234 MB)
2022-04-07 00:16:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 438000 (235 MB)
2022-04-07 00:16:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 439000 (235 MB)
2022-04-07 00:16:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 440000 (236 MB)
2022-04-07 00:16:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 441000 (236 MB)
2022-04-07 00:16:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 442000 (237 MB)
2022-04-07 00:16:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 443000 (237 MB)
2022-04-07 00:16:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 444000 (238 MB)
2022-04-07 00:16:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 445000 (238 MB)
2022-04-07 00:16:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 446000 (239 MB)
2022-04-07 00:16:20 source > 2022-04-07 00:16:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 410000
2022-04-07 00:16:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 447000 (239 MB)
2022-04-07 00:16:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 448000 (240 MB)
2022-04-07 00:16:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 449000 (240 MB)
2022-04-07 00:16:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 450000 (241 MB)
2022-04-07 00:16:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 451000 (241 MB)
2022-04-07 00:16:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 452000 (242 MB)
2022-04-07 00:16:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 453000 (242 MB)
2022-04-07 00:16:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 454000 (243 MB)
2022-04-07 00:16:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 455000 (243 MB)
2022-04-07 00:16:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 456000 (244 MB)
2022-04-07 00:16:24 source > 2022-04-07 00:16:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 420000
2022-04-07 00:16:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 457000 (244 MB)
2022-04-07 00:16:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 458000 (245 MB)
2022-04-07 00:16:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 459000 (245 MB)
2022-04-07 00:16:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 460000 (246 MB)
2022-04-07 00:16:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 461000 (246 MB)
2022-04-07 00:16:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 462000 (247 MB)
2022-04-07 00:16:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 463000 (247 MB)
2022-04-07 00:16:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 464000 (248 MB)
2022-04-07 00:16:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 465000 (248 MB)
2022-04-07 00:16:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 466000 (249 MB)
2022-04-07 00:16:28 source > 2022-04-07 00:16:27 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 430000
2022-04-07 00:16:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 467000 (249 MB)
2022-04-07 00:16:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 468000 (250 MB)
2022-04-07 00:16:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 469000 (250 MB)
2022-04-07 00:16:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 470000 (251 MB)
2022-04-07 00:16:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 471000 (251 MB)
2022-04-07 00:16:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 472000 (252 MB)
2022-04-07 00:16:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 473000 (252 MB)
2022-04-07 00:16:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 474000 (253 MB)
2022-04-07 00:16:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 475000 (253 MB)
2022-04-07 00:16:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 476000 (254 MB)
2022-04-07 00:16:33 source > 2022-04-07 00:16:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 440000
2022-04-07 00:16:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 477000 (254 MB)
2022-04-07 00:16:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 478000 (255 MB)
2022-04-07 00:16:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 479000 (255 MB)
2022-04-07 00:16:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 480000 (256 MB)
2022-04-07 00:16:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 481000 (256 MB)
2022-04-07 00:16:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 482000 (257 MB)
2022-04-07 00:16:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 483000 (257 MB)
2022-04-07 00:16:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 484000 (258 MB)
2022-04-07 00:16:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 485000 (258 MB)
2022-04-07 00:16:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 486000 (258 MB)
2022-04-07 00:16:37 source > 2022-04-07 00:16:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 450000
2022-04-07 00:16:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 487000 (259 MB)
2022-04-07 00:16:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 488000 (259 MB)
2022-04-07 00:16:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 489000 (260 MB)
2022-04-07 00:16:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 490000 (261 MB)
2022-04-07 00:16:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 491000 (261 MB)
2022-04-07 00:16:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 492000 (261 MB)
2022-04-07 00:16:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 493000 (262 MB)
2022-04-07 00:16:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 494000 (263 MB)
2022-04-07 00:16:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 495000 (263 MB)
2022-04-07 00:16:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 496000 (264 MB)
2022-04-07 00:16:42 source > 2022-04-07 00:16:41 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 460000
2022-04-07 00:16:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 497000 (264 MB)
2022-04-07 00:16:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 498000 (265 MB)
2022-04-07 00:16:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 499000 (265 MB)
2022-04-07 00:16:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 500000 (266 MB)
2022-04-07 00:16:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 501000 (266 MB)
2022-04-07 00:16:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 502000 (267 MB)
2022-04-07 00:16:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 503000 (267 MB)
2022-04-07 00:16:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 504000 (268 MB)
2022-04-07 00:16:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 505000 (268 MB)
2022-04-07 00:16:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 506000 (269 MB)
2022-04-07 00:16:46 source > 2022-04-07 00:16:45 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 470000
2022-04-07 00:16:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 507000 (269 MB)
2022-04-07 00:16:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 508000 (270 MB)
2022-04-07 00:16:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 509000 (270 MB)
2022-04-07 00:16:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 510000 (271 MB)
2022-04-07 00:16:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 511000 (271 MB)
2022-04-07 00:16:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 512000 (272 MB)
2022-04-07 00:16:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 513000 (272 MB)
2022-04-07 00:16:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 514000 (273 MB)
2022-04-07 00:16:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 515000 (274 MB)
2022-04-07 00:16:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 516000 (274 MB)
2022-04-07 00:16:50 source > 2022-04-07 00:16:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 480000
2022-04-07 00:16:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 517000 (275 MB)
2022-04-07 00:16:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 518000 (275 MB)
2022-04-07 00:16:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 519000 (276 MB)
2022-04-07 00:16:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 520000 (276 MB)
2022-04-07 00:16:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 521000 (276 MB)
2022-04-07 00:16:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 522000 (277 MB)
2022-04-07 00:16:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 523000 (277 MB)
2022-04-07 00:16:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 524000 (278 MB)
2022-04-07 00:16:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 525000 (278 MB)
2022-04-07 00:16:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 526000 (279 MB)
2022-04-07 00:16:54 source > 2022-04-07 00:16:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 490000
2022-04-07 00:16:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 527000 (279 MB)
2022-04-07 00:16:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 528000 (280 MB)
2022-04-07 00:16:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 529000 (280 MB)
2022-04-07 00:16:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 530000 (281 MB)
2022-04-07 00:16:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 531000 (281 MB)
2022-04-07 00:16:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 532000 (282 MB)
2022-04-07 00:16:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 533000 (282 MB)
2022-04-07 00:16:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 534000 (283 MB)
2022-04-07 00:16:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 535000 (284 MB)
2022-04-07 00:16:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 536000 (284 MB)
2022-04-07 00:16:58 source > 2022-04-07 00:16:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 500000
2022-04-07 00:16:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 537000 (285 MB)
2022-04-07 00:16:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 538000 (285 MB)
2022-04-07 00:16:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 539000 (286 MB)
2022-04-07 00:17:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 540000 (286 MB)
2022-04-07 00:17:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 541000 (287 MB)
2022-04-07 00:17:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 542000 (287 MB)
2022-04-07 00:17:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 543000 (288 MB)
2022-04-07 00:17:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 544000 (288 MB)
2022-04-07 00:17:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 545000 (289 MB)
2022-04-07 00:17:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 546000 (289 MB)
2022-04-07 00:17:02 source > 2022-04-07 00:17:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 510000
2022-04-07 00:17:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 547000 (290 MB)
2022-04-07 00:17:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 548000 (290 MB)
2022-04-07 00:17:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 549000 (291 MB)
2022-04-07 00:17:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 550000 (291 MB)
2022-04-07 00:17:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 551000 (292 MB)
2022-04-07 00:17:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 552000 (292 MB)
2022-04-07 00:17:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 553000 (293 MB)
2022-04-07 00:17:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 554000 (293 MB)
2022-04-07 00:17:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 555000 (294 MB)
2022-04-07 00:17:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 556000 (294 MB)
2022-04-07 00:17:07 source > 2022-04-07 00:17:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 520000
2022-04-07 00:17:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 557000 (295 MB)
2022-04-07 00:17:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 558000 (295 MB)
2022-04-07 00:17:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 559000 (296 MB)
2022-04-07 00:17:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 560000 (296 MB)
2022-04-07 00:17:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 561000 (297 MB)
2022-04-07 00:17:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 562000 (297 MB)
2022-04-07 00:17:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 563000 (298 MB)
2022-04-07 00:17:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 564000 (298 MB)
2022-04-07 00:17:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 565000 (299 MB)
2022-04-07 00:17:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 566000 (300 MB)
2022-04-07 00:17:11 source > 2022-04-07 00:17:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 530000
2022-04-07 00:17:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 567000 (300 MB)
2022-04-07 00:17:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 568000 (301 MB)
2022-04-07 00:17:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 569000 (301 MB)
2022-04-07 00:17:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 570000 (302 MB)
2022-04-07 00:17:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 571000 (302 MB)
2022-04-07 00:17:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 572000 (303 MB)
2022-04-07 00:17:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 573000 (303 MB)
2022-04-07 00:17:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 574000 (304 MB)
2022-04-07 00:17:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 575000 (304 MB)
2022-04-07 00:17:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 576000 (305 MB)
2022-04-07 00:17:15 source > 2022-04-07 00:17:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 540000
2022-04-07 00:17:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 577000 (305 MB)
2022-04-07 00:17:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 578000 (306 MB)
2022-04-07 00:17:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 579000 (306 MB)
2022-04-07 00:17:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 580000 (307 MB)
2022-04-07 00:17:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 581000 (307 MB)
2022-04-07 00:17:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 582000 (308 MB)
2022-04-07 00:17:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 583000 (308 MB)
2022-04-07 00:17:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 584000 (309 MB)
2022-04-07 00:17:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 585000 (309 MB)
2022-04-07 00:17:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 586000 (310 MB)
2022-04-07 00:17:19 source > 2022-04-07 00:17:17 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 550000
2022-04-07 00:17:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 587000 (310 MB)
2022-04-07 00:17:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 588000 (311 MB)
2022-04-07 00:17:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 589000 (312 MB)
2022-04-07 00:17:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 590000 (312 MB)
2022-04-07 00:17:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 591000 (313 MB)
2022-04-07 00:17:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 592000 (313 MB)
2022-04-07 00:17:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 593000 (314 MB)
2022-04-07 00:17:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 594000 (314 MB)
2022-04-07 00:17:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 595000 (315 MB)
2022-04-07 00:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 596000 (316 MB)
2022-04-07 00:17:23 source > 2022-04-07 00:17:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 560000
2022-04-07 00:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 597000 (316 MB)
2022-04-07 00:17:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 598000 (317 MB)
2022-04-07 00:17:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 599000 (317 MB)
2022-04-07 00:17:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 600000 (318 MB)
2022-04-07 00:17:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 601000 (318 MB)
2022-04-07 00:17:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 602000 (319 MB)
2022-04-07 00:17:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 603000 (319 MB)
2022-04-07 00:17:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 604000 (320 MB)
2022-04-07 00:17:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 605000 (321 MB)
2022-04-07 00:17:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 606000 (321 MB)
2022-04-07 00:17:27 source > 2022-04-07 00:17:26 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 570000
2022-04-07 00:17:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 607000 (321 MB)
2022-04-07 00:17:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 608000 (322 MB)
2022-04-07 00:17:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 609000 (322 MB)
2022-04-07 00:17:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 610000 (323 MB)
2022-04-07 00:17:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 611000 (324 MB)
2022-04-07 00:17:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 612000 (324 MB)
2022-04-07 00:17:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 613000 (325 MB)
2022-04-07 00:17:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 614000 (325 MB)
2022-04-07 00:17:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 615000 (326 MB)
2022-04-07 00:17:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 616000 (326 MB)
2022-04-07 00:17:32 source > 2022-04-07 00:17:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 580000
2022-04-07 00:17:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 617000 (327 MB)
2022-04-07 00:17:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 618000 (327 MB)
2022-04-07 00:17:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 619000 (328 MB)
2022-04-07 00:17:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 620000 (328 MB)
2022-04-07 00:17:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 621000 (329 MB)
2022-04-07 00:17:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 622000 (329 MB)
2022-04-07 00:17:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 623000 (330 MB)
2022-04-07 00:17:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 624000 (330 MB)
2022-04-07 00:17:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 625000 (331 MB)
2022-04-07 00:17:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 626000 (332 MB)
2022-04-07 00:17:36 source > 2022-04-07 00:17:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 590000
2022-04-07 00:17:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 627000 (332 MB)
2022-04-07 00:17:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 628000 (333 MB)
2022-04-07 00:17:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 629000 (333 MB)
2022-04-07 00:17:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 630000 (334 MB)
2022-04-07 00:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 631000 (334 MB)
2022-04-07 00:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 632000 (335 MB)
2022-04-07 00:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 633000 (335 MB)
2022-04-07 00:17:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 634000 (336 MB)
2022-04-07 00:17:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 635000 (336 MB)
2022-04-07 00:17:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 636000 (337 MB)
2022-04-07 00:17:41 source > 2022-04-07 00:17:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 600000
2022-04-07 00:17:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 637000 (337 MB)
2022-04-07 00:17:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 638000 (338 MB)
2022-04-07 00:17:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 639000 (339 MB)
2022-04-07 00:17:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 640000 (339 MB)
2022-04-07 00:17:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 641000 (340 MB)
2022-04-07 00:17:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 642000 (340 MB)
2022-04-07 00:17:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 643000 (341 MB)
2022-04-07 00:17:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 644000 (341 MB)
2022-04-07 00:17:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 645000 (342 MB)
2022-04-07 00:17:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 646000 (342 MB)
2022-04-07 00:17:45 source > 2022-04-07 00:17:44 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 610000
2022-04-07 00:17:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 647000 (343 MB)
2022-04-07 00:17:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 648000 (343 MB)
2022-04-07 00:17:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 649000 (344 MB)
2022-04-07 00:17:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 650000 (344 MB)
2022-04-07 00:17:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 651000 (345 MB)
2022-04-07 00:17:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 652000 (345 MB)
2022-04-07 00:17:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 653000 (346 MB)
2022-04-07 00:17:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 654000 (346 MB)
2022-04-07 00:17:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 655000 (347 MB)
2022-04-07 00:17:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 656000 (347 MB)
2022-04-07 00:17:49 source > 2022-04-07 00:17:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 620000
2022-04-07 00:17:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 657000 (348 MB)
2022-04-07 00:17:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 658000 (349 MB)
2022-04-07 00:17:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 659000 (349 MB)
2022-04-07 00:17:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 660000 (350 MB)
2022-04-07 00:17:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 661000 (350 MB)
2022-04-07 00:17:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 662000 (351 MB)
2022-04-07 00:17:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 663000 (351 MB)
2022-04-07 00:17:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 664000 (352 MB)
2022-04-07 00:17:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 665000 (352 MB)
2022-04-07 00:17:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 666000 (353 MB)
2022-04-07 00:17:54 source > 2022-04-07 00:17:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 630000
2022-04-07 00:17:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 667000 (353 MB)
2022-04-07 00:17:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 668000 (354 MB)
2022-04-07 00:17:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 669000 (354 MB)
2022-04-07 00:17:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 670000 (355 MB)
2022-04-07 00:17:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 671000 (355 MB)
2022-04-07 00:17:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 672000 (356 MB)
2022-04-07 00:17:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 673000 (356 MB)
2022-04-07 00:17:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 674000 (357 MB)
2022-04-07 00:17:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 675000 (357 MB)
2022-04-07 00:17:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 676000 (358 MB)
2022-04-07 00:17:58 source > 2022-04-07 00:17:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 640000
2022-04-07 00:17:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 677000 (358 MB)
2022-04-07 00:17:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 678000 (359 MB)
2022-04-07 00:17:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 679000 (359 MB)
2022-04-07 00:17:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 680000 (360 MB)
2022-04-07 00:17:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 681000 (360 MB)
2022-04-07 00:17:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 682000 (361 MB)
2022-04-07 00:18:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 683000 (361 MB)
2022-04-07 00:18:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 684000 (362 MB)
2022-04-07 00:18:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 685000 (362 MB)
2022-04-07 00:18:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 686000 (363 MB)
2022-04-07 00:18:02 source > 2022-04-07 00:18:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 650000
2022-04-07 00:18:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 687000 (363 MB)
2022-04-07 00:18:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 688000 (364 MB)
2022-04-07 00:18:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 689000 (364 MB)
2022-04-07 00:18:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 690000 (365 MB)
2022-04-07 00:18:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 691000 (366 MB)
2022-04-07 00:18:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 692000 (366 MB)
2022-04-07 00:18:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 693000 (367 MB)
2022-04-07 00:18:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 694000 (367 MB)
2022-04-07 00:18:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 695000 (368 MB)
2022-04-07 00:18:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 696000 (368 MB)
2022-04-07 00:18:06 source > 2022-04-07 00:18:05 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 660000
2022-04-07 00:18:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 697000 (369 MB)
2022-04-07 00:18:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 698000 (369 MB)
2022-04-07 00:18:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 699000 (370 MB)
2022-04-07 00:18:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 700000 (371 MB)
2022-04-07 00:18:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 701000 (371 MB)
2022-04-07 00:18:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 702000 (372 MB)
2022-04-07 00:18:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 703000 (372 MB)
2022-04-07 00:18:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 704000 (373 MB)
2022-04-07 00:18:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 705000 (373 MB)
2022-04-07 00:18:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 706000 (374 MB)
2022-04-07 00:18:10 source > 2022-04-07 00:18:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 670000
2022-04-07 00:18:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 707000 (374 MB)
2022-04-07 00:18:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 708000 (375 MB)
2022-04-07 00:18:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 709000 (375 MB)
2022-04-07 00:18:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 710000 (376 MB)
2022-04-07 00:18:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 711000 (377 MB)
2022-04-07 00:18:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 712000 (377 MB)
2022-04-07 00:18:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 713000 (378 MB)
2022-04-07 00:18:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 714000 (378 MB)
2022-04-07 00:18:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 715000 (379 MB)
2022-04-07 00:18:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 716000 (379 MB)
2022-04-07 00:18:14 source > 2022-04-07 00:18:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 680000
2022-04-07 00:18:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 717000 (380 MB)
2022-04-07 00:18:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 718000 (381 MB)
2022-04-07 00:18:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 719000 (381 MB)
2022-04-07 00:18:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 720000 (382 MB)
2022-04-07 00:18:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 721000 (382 MB)
2022-04-07 00:18:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 722000 (383 MB)
2022-04-07 00:18:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 723000 (384 MB)
2022-04-07 00:18:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 724000 (384 MB)
2022-04-07 00:18:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 725000 (385 MB)
2022-04-07 00:18:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 726000 (385 MB)
2022-04-07 00:18:18 source > 2022-04-07 00:18:17 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 690000
2022-04-07 00:18:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 727000 (386 MB)
2022-04-07 00:18:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 728000 (386 MB)
2022-04-07 00:18:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 729000 (387 MB)
2022-04-07 00:18:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 730000 (387 MB)
2022-04-07 00:18:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 731000 (388 MB)
2022-04-07 00:18:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 732000 (388 MB)
2022-04-07 00:18:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 733000 (389 MB)
2022-04-07 00:18:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 734000 (389 MB)
2022-04-07 00:18:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 735000 (390 MB)
2022-04-07 00:18:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 736000 (390 MB)
2022-04-07 00:18:22 source > 2022-04-07 00:18:21 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 700000
2022-04-07 00:18:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 737000 (391 MB)
2022-04-07 00:18:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 738000 (391 MB)
2022-04-07 00:18:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 739000 (392 MB)
2022-04-07 00:18:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 740000 (392 MB)
2022-04-07 00:18:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 741000 (393 MB)
2022-04-07 00:18:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 742000 (393 MB)
2022-04-07 00:18:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 743000 (394 MB)
2022-04-07 00:18:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 744000 (394 MB)
2022-04-07 00:18:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 745000 (395 MB)
2022-04-07 00:18:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 746000 (395 MB)
2022-04-07 00:18:25 source > 2022-04-07 00:18:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 710000
2022-04-07 00:18:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 747000 (396 MB)
2022-04-07 00:18:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 748000 (397 MB)
2022-04-07 00:18:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 749000 (397 MB)
2022-04-07 00:18:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 750000 (398 MB)
2022-04-07 00:18:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 751000 (398 MB)
2022-04-07 00:18:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 752000 (399 MB)
2022-04-07 00:18:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 753000 (399 MB)
2022-04-07 00:18:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 754000 (400 MB)
2022-04-07 00:18:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 755000 (400 MB)
2022-04-07 00:18:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 756000 (401 MB)
2022-04-07 00:18:29 source > 2022-04-07 00:18:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 720000
2022-04-07 00:18:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 757000 (401 MB)
2022-04-07 00:18:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 758000 (402 MB)
2022-04-07 00:18:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 759000 (402 MB)
2022-04-07 00:18:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 760000 (403 MB)
2022-04-07 00:18:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 761000 (403 MB)
2022-04-07 00:18:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 762000 (404 MB)
2022-04-07 00:18:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 763000 (404 MB)
2022-04-07 00:18:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 764000 (405 MB)
2022-04-07 00:18:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 765000 (405 MB)
2022-04-07 00:18:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 766000 (406 MB)
2022-04-07 00:18:33 source > 2022-04-07 00:18:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 730000
2022-04-07 00:18:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 767000 (406 MB)
2022-04-07 00:18:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 768000 (407 MB)
2022-04-07 00:18:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 769000 (407 MB)
2022-04-07 00:18:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 770000 (408 MB)
2022-04-07 00:18:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 771000 (408 MB)
2022-04-07 00:18:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 772000 (409 MB)
2022-04-07 00:18:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 773000 (409 MB)
2022-04-07 00:18:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 774000 (410 MB)
2022-04-07 00:18:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 775000 (410 MB)
2022-04-07 00:18:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 776000 (411 MB)
2022-04-07 00:18:37 source > 2022-04-07 00:18:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 740000
2022-04-07 00:18:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 777000 (411 MB)
2022-04-07 00:18:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 778000 (412 MB)
2022-04-07 00:18:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 779000 (412 MB)
2022-04-07 00:18:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 780000 (413 MB)
2022-04-07 00:18:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 781000 (414 MB)
2022-04-07 00:18:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 782000 (414 MB)
2022-04-07 00:18:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 783000 (415 MB)
2022-04-07 00:18:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 784000 (415 MB)
2022-04-07 00:18:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 785000 (416 MB)
2022-04-07 00:18:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 786000 (416 MB)
2022-04-07 00:18:42 source > 2022-04-07 00:18:41 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 750000
2022-04-07 00:18:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 787000 (417 MB)
2022-04-07 00:18:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 788000 (417 MB)
2022-04-07 00:18:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 789000 (418 MB)
2022-04-07 00:18:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 790000 (418 MB)
2022-04-07 00:18:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 791000 (419 MB)
2022-04-07 00:18:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 792000 (419 MB)
2022-04-07 00:18:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 793000 (420 MB)
2022-04-07 00:18:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 794000 (420 MB)
2022-04-07 00:18:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 795000 (421 MB)
2022-04-07 00:18:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 796000 (421 MB)
2022-04-07 00:18:45 source > 2022-04-07 00:18:44 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 760000
2022-04-07 00:18:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 797000 (422 MB)
2022-04-07 00:18:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 798000 (422 MB)
2022-04-07 00:18:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 799000 (423 MB)
2022-04-07 00:18:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 800000 (423 MB)
2022-04-07 00:18:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 801000 (424 MB)
2022-04-07 00:18:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 802000 (424 MB)
2022-04-07 00:18:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 803000 (425 MB)
2022-04-07 00:18:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 804000 (426 MB)
2022-04-07 00:18:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 805000 (426 MB)
2022-04-07 00:18:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 806000 (427 MB)
2022-04-07 00:18:49 source > 2022-04-07 00:18:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 770000
2022-04-07 00:18:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 807000 (427 MB)
2022-04-07 00:18:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 808000 (428 MB)
2022-04-07 00:18:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 809000 (428 MB)
2022-04-07 00:18:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 810000 (429 MB)
2022-04-07 00:18:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 811000 (429 MB)
2022-04-07 00:18:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 812000 (430 MB)
2022-04-07 00:18:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 813000 (430 MB)
2022-04-07 00:18:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 814000 (431 MB)
2022-04-07 00:18:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 815000 (431 MB)
2022-04-07 00:18:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 816000 (432 MB)
2022-04-07 00:18:53 source > 2022-04-07 00:18:52 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 780000
2022-04-07 00:18:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 817000 (433 MB)
2022-04-07 00:18:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 818000 (433 MB)
2022-04-07 00:18:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 819000 (434 MB)
2022-04-07 00:18:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 820000 (434 MB)
2022-04-07 00:18:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 821000 (435 MB)
2022-04-07 00:18:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 822000 (435 MB)
2022-04-07 00:18:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 823000 (436 MB)
2022-04-07 00:18:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 824000 (436 MB)
2022-04-07 00:18:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 825000 (437 MB)
2022-04-07 00:18:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 826000 (437 MB)
2022-04-07 00:18:57 source > 2022-04-07 00:18:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 790000
2022-04-07 00:18:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 827000 (438 MB)
2022-04-07 00:18:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 828000 (438 MB)
2022-04-07 00:18:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 829000 (439 MB)
2022-04-07 00:18:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 830000 (439 MB)
2022-04-07 00:18:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 831000 (440 MB)
2022-04-07 00:18:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 832000 (440 MB)
2022-04-07 00:18:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 833000 (441 MB)
2022-04-07 00:18:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 834000 (442 MB)
2022-04-07 00:18:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 835000 (442 MB)
2022-04-07 00:19:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 836000 (443 MB)
2022-04-07 00:19:00 source > 2022-04-07 00:18:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 800000
2022-04-07 00:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 837000 (443 MB)
2022-04-07 00:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 838000 (444 MB)
2022-04-07 00:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 839000 (444 MB)
2022-04-07 00:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 840000 (445 MB)
2022-04-07 00:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 841000 (445 MB)
2022-04-07 00:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 842000 (446 MB)
2022-04-07 00:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 843000 (446 MB)
2022-04-07 00:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 844000 (447 MB)
2022-04-07 00:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 845000 (447 MB)
2022-04-07 00:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 846000 (447 MB)
2022-04-07 00:19:04 source > 2022-04-07 00:19:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 810000
2022-04-07 00:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 847000 (448 MB)
2022-04-07 00:19:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 848000 (449 MB)
2022-04-07 00:19:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 849000 (449 MB)
2022-04-07 00:19:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 850000 (450 MB)
2022-04-07 00:19:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 851000 (450 MB)
2022-04-07 00:19:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 852000 (451 MB)
2022-04-07 00:19:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 853000 (451 MB)
2022-04-07 00:19:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 854000 (452 MB)
2022-04-07 00:19:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 855000 (452 MB)
2022-04-07 00:19:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 856000 (453 MB)
2022-04-07 00:19:08 source > 2022-04-07 00:19:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 820000
2022-04-07 00:19:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 857000 (454 MB)
2022-04-07 00:19:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 858000 (454 MB)
2022-04-07 00:19:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 859000 (455 MB)
2022-04-07 00:19:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 860000 (455 MB)
2022-04-07 00:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 861000 (456 MB)
2022-04-07 00:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 862000 (456 MB)
2022-04-07 00:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 863000 (457 MB)
2022-04-07 00:19:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 864000 (457 MB)
2022-04-07 00:19:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 865000 (458 MB)
2022-04-07 00:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 866000 (458 MB)
2022-04-07 00:19:12 source > 2022-04-07 00:19:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 830000
2022-04-07 00:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 867000 (459 MB)
2022-04-07 00:19:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 868000 (459 MB)
2022-04-07 00:19:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 869000 (460 MB)
2022-04-07 00:19:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 870000 (460 MB)
2022-04-07 00:19:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 871000 (461 MB)
2022-04-07 00:19:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 872000 (462 MB)
2022-04-07 00:19:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 873000 (462 MB)
2022-04-07 00:19:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 874000 (463 MB)
2022-04-07 00:19:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 875000 (463 MB)
2022-04-07 00:19:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 876000 (464 MB)
2022-04-07 00:19:16 source > 2022-04-07 00:19:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 840000
2022-04-07 00:19:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 877000 (464 MB)
2022-04-07 00:19:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 878000 (465 MB)
2022-04-07 00:19:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 879000 (465 MB)
2022-04-07 00:19:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 880000 (466 MB)
2022-04-07 00:19:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 881000 (467 MB)
2022-04-07 00:19:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 882000 (467 MB)
2022-04-07 00:19:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 883000 (468 MB)
2022-04-07 00:19:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 884000 (468 MB)
2022-04-07 00:19:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 885000 (469 MB)
2022-04-07 00:19:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 886000 (469 MB)
2022-04-07 00:19:20 source > 2022-04-07 00:19:19 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 850000
2022-04-07 00:19:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 887000 (470 MB)
2022-04-07 00:19:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 888000 (470 MB)
2022-04-07 00:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 889000 (471 MB)
2022-04-07 00:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 890000 (471 MB)
2022-04-07 00:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 891000 (472 MB)
2022-04-07 00:19:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 892000 (473 MB)
2022-04-07 00:19:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 893000 (473 MB)
2022-04-07 00:19:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 894000 (474 MB)
2022-04-07 00:19:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 895000 (474 MB)
2022-04-07 00:19:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 896000 (475 MB)
2022-04-07 00:19:25 source > 2022-04-07 00:19:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 860000
2022-04-07 00:19:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 897000 (476 MB)
2022-04-07 00:19:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 898000 (476 MB)
2022-04-07 00:19:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 899000 (477 MB)
2022-04-07 00:19:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 900000 (477 MB)
2022-04-07 00:19:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 901000 (478 MB)
2022-04-07 00:19:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 902000 (478 MB)
2022-04-07 00:19:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 903000 (479 MB)
2022-04-07 00:19:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 904000 (479 MB)
2022-04-07 00:19:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 905000 (480 MB)
2022-04-07 00:19:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 906000 (481 MB)
2022-04-07 00:19:29 source > 2022-04-07 00:19:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 870000
2022-04-07 00:19:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 907000 (481 MB)
2022-04-07 00:19:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 908000 (482 MB)
2022-04-07 00:19:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 909000 (482 MB)
2022-04-07 00:19:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 910000 (483 MB)
2022-04-07 00:19:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 911000 (483 MB)
2022-04-07 00:19:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 912000 (484 MB)
2022-04-07 00:19:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 913000 (485 MB)
2022-04-07 00:19:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 914000 (485 MB)
2022-04-07 00:19:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 915000 (486 MB)
2022-04-07 00:19:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 916000 (486 MB)
2022-04-07 00:19:33 source > 2022-04-07 00:19:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 880000
2022-04-07 00:19:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 917000 (487 MB)
2022-04-07 00:19:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 918000 (487 MB)
2022-04-07 00:19:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 919000 (488 MB)
2022-04-07 00:19:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 920000 (488 MB)
2022-04-07 00:19:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 921000 (489 MB)
2022-04-07 00:19:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 922000 (489 MB)
2022-04-07 00:19:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 923000 (490 MB)
2022-04-07 00:19:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 924000 (491 MB)
2022-04-07 00:19:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 925000 (491 MB)
2022-04-07 00:19:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 926000 (492 MB)
2022-04-07 00:19:38 source > 2022-04-07 00:19:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 890000
2022-04-07 00:19:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 927000 (492 MB)
2022-04-07 00:19:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 928000 (493 MB)
2022-04-07 00:19:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 929000 (493 MB)
2022-04-07 00:19:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 930000 (494 MB)
2022-04-07 00:19:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 931000 (494 MB)
2022-04-07 00:19:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 932000 (495 MB)
2022-04-07 00:19:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 933000 (495 MB)
2022-04-07 00:19:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 934000 (496 MB)
2022-04-07 00:19:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 935000 (496 MB)
2022-04-07 00:19:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 936000 (497 MB)
2022-04-07 00:19:41 source > 2022-04-07 00:19:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 900000
2022-04-07 00:19:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 937000 (497 MB)
2022-04-07 00:19:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 938000 (498 MB)
2022-04-07 00:19:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 939000 (499 MB)
2022-04-07 00:19:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 940000 (499 MB)
2022-04-07 00:19:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 941000 (500 MB)
2022-04-07 00:19:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 942000 (500 MB)
2022-04-07 00:19:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 943000 (501 MB)
2022-04-07 00:19:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 944000 (501 MB)
2022-04-07 00:19:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 945000 (502 MB)
2022-04-07 00:19:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 946000 (503 MB)
2022-04-07 00:19:46 source > 2022-04-07 00:19:45 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 910000
2022-04-07 00:19:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 947000 (503 MB)
2022-04-07 00:19:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 948000 (504 MB)
2022-04-07 00:19:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 949000 (504 MB)
2022-04-07 00:19:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 950000 (505 MB)
2022-04-07 00:19:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 951000 (506 MB)
2022-04-07 00:19:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 952000 (506 MB)
2022-04-07 00:19:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 953000 (507 MB)
2022-04-07 00:19:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 954000 (507 MB)
2022-04-07 00:19:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 955000 (508 MB)
2022-04-07 00:19:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 956000 (508 MB)
2022-04-07 00:19:50 source > 2022-04-07 00:19:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 920000
2022-04-07 00:19:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 957000 (509 MB)
2022-04-07 00:19:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 958000 (509 MB)
2022-04-07 00:19:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 959000 (510 MB)
2022-04-07 00:19:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 960000 (511 MB)
2022-04-07 00:19:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 961000 (511 MB)
2022-04-07 00:19:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 962000 (512 MB)
2022-04-07 00:19:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 963000 (512 MB)
2022-04-07 00:19:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 964000 (513 MB)
2022-04-07 00:19:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 965000 (513 MB)
2022-04-07 00:19:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 966000 (514 MB)
2022-04-07 00:19:54 source > 2022-04-07 00:19:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 930000
2022-04-07 00:19:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 967000 (514 MB)
2022-04-07 00:19:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 968000 (515 MB)
2022-04-07 00:19:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 969000 (515 MB)
2022-04-07 00:19:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 970000 (516 MB)
2022-04-07 00:19:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 971000 (516 MB)
2022-04-07 00:19:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 972000 (517 MB)
2022-04-07 00:19:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 973000 (518 MB)
2022-04-07 00:19:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 974000 (518 MB)
2022-04-07 00:19:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 975000 (519 MB)
2022-04-07 00:19:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 976000 (519 MB)
2022-04-07 00:19:58 source > 2022-04-07 00:19:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 940000
2022-04-07 00:19:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 977000 (520 MB)
2022-04-07 00:19:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 978000 (520 MB)
2022-04-07 00:19:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 979000 (521 MB)
2022-04-07 00:20:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 980000 (521 MB)
2022-04-07 00:20:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 981000 (522 MB)
2022-04-07 00:20:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 982000 (522 MB)
2022-04-07 00:20:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 983000 (523 MB)
2022-04-07 00:20:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 984000 (523 MB)
2022-04-07 00:20:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 985000 (524 MB)
2022-04-07 00:20:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 986000 (524 MB)
2022-04-07 00:20:02 source > 2022-04-07 00:20:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 950000
2022-04-07 00:20:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 987000 (525 MB)
2022-04-07 00:20:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 988000 (525 MB)
2022-04-07 00:20:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 989000 (526 MB)
2022-04-07 00:20:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 990000 (526 MB)
2022-04-07 00:20:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 991000 (527 MB)
2022-04-07 00:20:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 992000 (528 MB)
2022-04-07 00:20:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 993000 (528 MB)
2022-04-07 00:20:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 994000 (529 MB)
2022-04-07 00:20:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 995000 (529 MB)
2022-04-07 00:20:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 996000 (530 MB)
2022-04-07 00:20:06 source > 2022-04-07 00:20:05 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 960000
2022-04-07 00:20:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 997000 (530 MB)
2022-04-07 00:20:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 998000 (531 MB)
2022-04-07 00:20:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 999000 (531 MB)
2022-04-07 00:20:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000000 (532 MB)
2022-04-07 00:20:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1001000 (532 MB)
2022-04-07 00:20:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1002000 (533 MB)
2022-04-07 00:20:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1003000 (533 MB)
2022-04-07 00:20:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1004000 (534 MB)
2022-04-07 00:20:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1005000 (534 MB)
2022-04-07 00:20:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1006000 (535 MB)
2022-04-07 00:20:10 source > 2022-04-07 00:20:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 970000
2022-04-07 00:20:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1007000 (535 MB)
2022-04-07 00:20:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1008000 (536 MB)
2022-04-07 00:20:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1009000 (536 MB)
2022-04-07 00:20:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1010000 (537 MB)
2022-04-07 00:20:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1011000 (537 MB)
2022-04-07 00:20:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1012000 (538 MB)
2022-04-07 00:20:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1013000 (538 MB)
2022-04-07 00:20:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1014000 (539 MB)
2022-04-07 00:20:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1015000 (539 MB)
2022-04-07 00:20:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1016000 (540 MB)
2022-04-07 00:20:15 source > 2022-04-07 00:20:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 980000
2022-04-07 00:20:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1017000 (540 MB)
2022-04-07 00:20:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1018000 (541 MB)
2022-04-07 00:20:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1019000 (541 MB)
2022-04-07 00:20:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1020000 (542 MB)
2022-04-07 00:20:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1021000 (542 MB)
2022-04-07 00:20:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1022000 (543 MB)
2022-04-07 00:20:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1023000 (544 MB)
2022-04-07 00:20:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1024000 (544 MB)
2022-04-07 00:20:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1025000 (544 MB)
2022-04-07 00:20:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1026000 (545 MB)
2022-04-07 00:20:19 source > 2022-04-07 00:20:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 990000
2022-04-07 00:20:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1027000 (545 MB)
2022-04-07 00:20:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1028000 (546 MB)
2022-04-07 00:20:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1029000 (546 MB)
2022-04-07 00:20:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1030000 (547 MB)
2022-04-07 00:20:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1031000 (548 MB)
2022-04-07 00:20:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1032000 (548 MB)
2022-04-07 00:20:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1033000 (549 MB)
2022-04-07 00:20:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1034000 (549 MB)
2022-04-07 00:20:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1035000 (550 MB)
2022-04-07 00:20:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1036000 (550 MB)
2022-04-07 00:20:23 source > 2022-04-07 00:20:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1000000
2022-04-07 00:20:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1037000 (551 MB)
2022-04-07 00:20:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1038000 (551 MB)
2022-04-07 00:20:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1039000 (552 MB)
2022-04-07 00:20:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1040000 (552 MB)
2022-04-07 00:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1041000 (553 MB)
2022-04-07 00:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1042000 (554 MB)
2022-04-07 00:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1043000 (554 MB)
2022-04-07 00:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1044000 (555 MB)
2022-04-07 00:20:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1045000 (555 MB)
2022-04-07 00:20:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1046000 (556 MB)
2022-04-07 00:20:27 source > 2022-04-07 00:20:26 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1010000
2022-04-07 00:20:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1047000 (556 MB)
2022-04-07 00:20:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1048000 (557 MB)
2022-04-07 00:20:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1049000 (557 MB)
2022-04-07 00:20:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1050000 (558 MB)
2022-04-07 00:20:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1051000 (558 MB)
2022-04-07 00:20:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1052000 (559 MB)
2022-04-07 00:20:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1053000 (559 MB)
2022-04-07 00:20:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1054000 (560 MB)
2022-04-07 00:20:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1055000 (560 MB)
2022-04-07 00:20:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1056000 (561 MB)
2022-04-07 00:20:31 source > 2022-04-07 00:20:30 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1020000
2022-04-07 00:20:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1057000 (561 MB)
2022-04-07 00:20:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1058000 (562 MB)
2022-04-07 00:20:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1059000 (563 MB)
2022-04-07 00:20:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1060000 (563 MB)
2022-04-07 00:20:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1061000 (564 MB)
2022-04-07 00:20:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1062000 (564 MB)
2022-04-07 00:20:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1063000 (565 MB)
2022-04-07 00:20:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1064000 (565 MB)
2022-04-07 00:20:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1065000 (566 MB)
2022-04-07 00:20:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1066000 (566 MB)
2022-04-07 00:20:34 source > 2022-04-07 00:20:33 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1030000
2022-04-07 00:20:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1067000 (567 MB)
2022-04-07 00:20:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1068000 (567 MB)
2022-04-07 00:20:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1069000 (568 MB)
2022-04-07 00:20:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1070000 (568 MB)
2022-04-07 00:20:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1071000 (569 MB)
2022-04-07 00:20:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1072000 (569 MB)
2022-04-07 00:20:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1073000 (570 MB)
2022-04-07 00:20:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1074000 (570 MB)
2022-04-07 00:20:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1075000 (571 MB)
2022-04-07 00:20:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1076000 (572 MB)
2022-04-07 00:20:38 source > 2022-04-07 00:20:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1040000
2022-04-07 00:20:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1077000 (572 MB)
2022-04-07 00:20:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1078000 (573 MB)
2022-04-07 00:20:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1079000 (573 MB)
2022-04-07 00:20:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1080000 (574 MB)
2022-04-07 00:20:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1081000 (574 MB)
2022-04-07 00:20:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1082000 (575 MB)
2022-04-07 00:20:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1083000 (575 MB)
2022-04-07 00:20:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1084000 (576 MB)
2022-04-07 00:20:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1085000 (576 MB)
2022-04-07 00:20:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1086000 (577 MB)
2022-04-07 00:20:43 source > 2022-04-07 00:20:41 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1050000
2022-04-07 00:20:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1087000 (577 MB)
2022-04-07 00:20:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1088000 (578 MB)
2022-04-07 00:20:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1089000 (578 MB)
2022-04-07 00:20:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1090000 (579 MB)
2022-04-07 00:20:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1091000 (579 MB)
2022-04-07 00:20:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1092000 (580 MB)
2022-04-07 00:20:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1093000 (580 MB)
2022-04-07 00:20:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1094000 (581 MB)
2022-04-07 00:20:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1095000 (581 MB)
2022-04-07 00:20:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1096000 (582 MB)
2022-04-07 00:20:46 source > 2022-04-07 00:20:46 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1060000
2022-04-07 00:20:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1097000 (582 MB)
2022-04-07 00:20:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1098000 (583 MB)
2022-04-07 00:20:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1099000 (583 MB)
2022-04-07 00:20:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1100000 (584 MB)
2022-04-07 00:20:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1101000 (584 MB)
2022-04-07 00:20:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1102000 (585 MB)
2022-04-07 00:20:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1103000 (585 MB)
2022-04-07 00:20:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1104000 (586 MB)
2022-04-07 00:20:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1105000 (586 MB)
2022-04-07 00:20:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1106000 (587 MB)
2022-04-07 00:20:51 source > 2022-04-07 00:20:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1070000
2022-04-07 00:20:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1107000 (588 MB)
2022-04-07 00:20:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1108000 (588 MB)
2022-04-07 00:20:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1109000 (589 MB)
2022-04-07 00:20:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1110000 (589 MB)
2022-04-07 00:20:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1111000 (590 MB)
2022-04-07 00:20:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1112000 (590 MB)
2022-04-07 00:20:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1113000 (591 MB)
2022-04-07 00:20:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1114000 (591 MB)
2022-04-07 00:20:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1115000 (592 MB)
2022-04-07 00:20:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1116000 (592 MB)
2022-04-07 00:20:54 source > 2022-04-07 00:20:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1080000
2022-04-07 00:20:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1117000 (593 MB)
2022-04-07 00:20:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1118000 (593 MB)
2022-04-07 00:20:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1119000 (594 MB)
2022-04-07 00:20:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1120000 (594 MB)
2022-04-07 00:20:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1121000 (595 MB)
2022-04-07 00:20:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1122000 (595 MB)
2022-04-07 00:20:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1123000 (596 MB)
2022-04-07 00:20:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1124000 (597 MB)
2022-04-07 00:20:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1125000 (597 MB)
2022-04-07 00:20:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1126000 (598 MB)
2022-04-07 00:20:58 source > 2022-04-07 00:20:58 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1090000
2022-04-07 00:20:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1127000 (598 MB)
2022-04-07 00:20:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1128000 (599 MB)
2022-04-07 00:20:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1129000 (599 MB)
2022-04-07 00:21:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1130000 (600 MB)
2022-04-07 00:21:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1131000 (601 MB)
2022-04-07 00:21:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1132000 (603 MB)
2022-04-07 00:21:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1133000 (606 MB)
2022-04-07 00:21:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1134000 (609 MB)
2022-04-07 00:21:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1135000 (611 MB)
2022-04-07 00:21:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1136000 (616 MB)
2022-04-07 00:21:09 source > 2022-04-07 00:21:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1100000
2022-04-07 00:21:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1137000 (618 MB)
2022-04-07 00:21:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1138000 (620 MB)
2022-04-07 00:21:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1139000 (631 MB)
2022-04-07 00:21:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1140000 (638 MB)
2022-04-07 00:21:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1141000 (642 MB)
2022-04-07 00:21:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1142000 (649 MB)
2022-04-07 00:21:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1143000 (652 MB)
2022-04-07 00:21:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1144000 (661 MB)
2022-04-07 00:21:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1145000 (674 MB)
2022-04-07 00:21:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1146000 (677 MB)
2022-04-07 00:21:37 source > 2022-04-07 00:21:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1110000
2022-04-07 00:21:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1147000 (680 MB)
2022-04-07 00:21:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1148000 (684 MB)
2022-04-07 00:21:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1149000 (688 MB)
2022-04-07 00:21:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1150000 (690 MB)
2022-04-07 00:21:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1151000 (698 MB)
2022-04-07 00:21:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1152000 (702 MB)
2022-04-07 00:21:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1153000 (705 MB)
2022-04-07 00:21:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1154000 (714 MB)
2022-04-07 00:21:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1155000 (720 MB)
2022-04-07 00:21:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1156000 (723 MB)
2022-04-07 00:21:56 source > 2022-04-07 00:21:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1120000
2022-04-07 00:21:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1157000 (726 MB)
2022-04-07 00:21:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1158000 (730 MB)
2022-04-07 00:21:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1159000 (732 MB)
2022-04-07 00:22:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1160000 (736 MB)
2022-04-07 00:22:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1161000 (739 MB)
2022-04-07 00:22:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1162000 (741 MB)
2022-04-07 00:22:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1163000 (745 MB)
2022-04-07 00:22:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1164000 (752 MB)
2022-04-07 00:22:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1165000 (757 MB)
2022-04-07 00:22:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1166000 (761 MB)
2022-04-07 00:22:12 source > 2022-04-07 00:22:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1130000
2022-04-07 00:22:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1167000 (763 MB)
2022-04-07 00:22:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1168000 (765 MB)
2022-04-07 00:22:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1169000 (768 MB)
2022-04-07 00:22:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1170000 (771 MB)
2022-04-07 00:22:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1171000 (775 MB)
2022-04-07 00:22:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1172000 (779 MB)
2022-04-07 00:22:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1173000 (792 MB)
2022-04-07 00:22:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1174000 (796 MB)
2022-04-07 00:22:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1175000 (799 MB)
2022-04-07 00:22:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1176000 (802 MB)
2022-04-07 00:22:30 source > 2022-04-07 00:22:29 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1140000
2022-04-07 00:22:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1177000 (805 MB)
2022-04-07 00:22:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1178000 (807 MB)
2022-04-07 00:22:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1179000 (810 MB)
2022-04-07 00:22:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1180000 (814 MB)
2022-04-07 00:22:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1181000 (817 MB)
2022-04-07 00:22:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1182000 (822 MB)
2022-04-07 00:22:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1183000 (824 MB)
2022-04-07 00:22:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1184000 (827 MB)
2022-04-07 00:22:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1185000 (831 MB)
2022-04-07 00:22:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1186000 (833 MB)
2022-04-07 00:22:44 source > 2022-04-07 00:22:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1150000
2022-04-07 00:22:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1187000 (836 MB)
2022-04-07 00:22:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1188000 (842 MB)
2022-04-07 00:22:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1189000 (846 MB)
2022-04-07 00:22:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1190000 (852 MB)
2022-04-07 00:22:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1191000 (858 MB)
2022-04-07 00:22:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1192000 (862 MB)
2022-04-07 00:22:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1193000 (864 MB)
2022-04-07 00:22:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1194000 (867 MB)
2022-04-07 00:22:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1195000 (870 MB)
2022-04-07 00:23:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1196000 (873 MB)
2022-04-07 00:23:01 source > 2022-04-07 00:23:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1160000
2022-04-07 00:23:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1197000 (875 MB)
2022-04-07 00:23:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1198000 (878 MB)
2022-04-07 00:23:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1199000 (881 MB)
2022-04-07 00:23:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1200000 (885 MB)
2022-04-07 00:23:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1201000 (888 MB)
2022-04-07 00:23:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1202000 (890 MB)
2022-04-07 00:23:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1203000 (893 MB)
2022-04-07 00:23:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1204000 (898 MB)
2022-04-07 00:23:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1205000 (900 MB)
2022-04-07 00:23:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1206000 (905 MB)
2022-04-07 00:23:14 source > 2022-04-07 00:23:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1170000
2022-04-07 00:23:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1207000 (907 MB)
2022-04-07 00:23:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1208000 (910 MB)
2022-04-07 00:23:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1209000 (916 MB)
2022-04-07 00:23:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1210000 (921 MB)
2022-04-07 00:23:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1211000 (926 MB)
2022-04-07 00:23:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1212000 (932 MB)
2022-04-07 00:23:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1213000 (936 MB)
2022-04-07 00:23:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1214000 (939 MB)
2022-04-07 00:23:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1215000 (943 MB)
2022-04-07 00:23:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1216000 (950 MB)
2022-04-07 00:23:34 source > 2022-04-07 00:23:34 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1180000
2022-04-07 00:23:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1217000 (955 MB)
2022-04-07 00:23:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1218000 (957 MB)
2022-04-07 00:23:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1219000 (961 MB)
2022-04-07 00:23:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1220000 (967 MB)
2022-04-07 00:23:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1221000 (970 MB)
2022-04-07 00:23:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1222000 (978 MB)
2022-04-07 00:23:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1223000 (980 MB)
2022-04-07 00:23:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1224000 (983 MB)
2022-04-07 00:23:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1225000 (985 MB)
2022-04-07 00:23:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1226000 (987 MB)
2022-04-07 00:23:50 source > 2022-04-07 00:23:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1190000
2022-04-07 00:23:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1227000 (990 MB)
2022-04-07 00:23:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1228000 (993 MB)
2022-04-07 00:23:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1229000 (996 MB)
2022-04-07 00:23:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1230000 (999 MB)
2022-04-07 00:23:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1231000 (1003 MB)
2022-04-07 00:23:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1232000 (1005 MB)
2022-04-07 00:23:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1233000 (1008 MB)
2022-04-07 00:23:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1234000 (1012 MB)
2022-04-07 00:24:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1235000 (1015 MB)
2022-04-07 00:24:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1236000 (1018 MB)
2022-04-07 00:24:02 source > 2022-04-07 00:24:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1200000
2022-04-07 00:24:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1237000 (1021 MB)
2022-04-07 00:24:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1238000 (1 GB)
2022-04-07 00:24:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1239000 (1 GB)
2022-04-07 00:24:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1240000 (1 GB)
2022-04-07 00:24:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1241000 (1 GB)
2022-04-07 00:24:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1242000 (1 GB)
2022-04-07 00:24:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1243000 (1 GB)
2022-04-07 00:24:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1244000 (1 GB)
2022-04-07 00:24:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1245000 (1 GB)
2022-04-07 00:24:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1246000 (1 GB)
2022-04-07 00:24:18 source > 2022-04-07 00:24:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1210000
2022-04-07 00:24:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1247000 (1 GB)
2022-04-07 00:24:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1248000 (1 GB)
2022-04-07 00:24:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1249000 (1 GB)
2022-04-07 00:24:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1250000 (1 GB)
2022-04-07 00:24:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1251000 (1 GB)
2022-04-07 00:24:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1252000 (1 GB)
2022-04-07 00:24:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1253000 (1 GB)
2022-04-07 00:24:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1254000 (1 GB)
2022-04-07 00:24:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1255000 (1 GB)
2022-04-07 00:24:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1256000 (1 GB)
2022-04-07 00:24:33 source > 2022-04-07 00:24:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1220000
2022-04-07 00:24:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1257000 (1 GB)
2022-04-07 00:24:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1258000 (1 GB)
2022-04-07 00:24:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1259000 (1 GB)
2022-04-07 00:24:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1260000 (1 GB)
2022-04-07 00:24:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1261000 (1 GB)
2022-04-07 00:24:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1262000 (1 GB)
2022-04-07 00:24:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1263000 (1 GB)
2022-04-07 00:24:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1264000 (1 GB)
2022-04-07 00:24:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1265000 (1 GB)
2022-04-07 00:24:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1266000 (1 GB)
2022-04-07 00:24:49 source > 2022-04-07 00:24:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream provider_calc_result. Records read: 1230000
2022-04-07 00:24:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1267000 (1 GB)
2022-04-07 00:24:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1268000 (1 GB)
2022-04-07 00:24:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1269000 (1 GB)
2022-04-07 00:24:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1270000 (1 GB)
2022-04-07 00:24:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1271000 (1 GB)
2022-04-07 00:24:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1272000 (1 GB)
2022-04-07 00:24:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1273000 (1 GB)
2022-04-07 00:25:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1274000 (1 GB)
2022-04-07 00:25:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1275000 (1 GB)
2022-04-07 00:27:22 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 69.999395343s. [closed=[], open=[[buffered_nanos=9946123, remote_addr=airbyte-temporal/172.18.0.6:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.8.1.jar:?]
	at jdk.proxy2.$Proxy53.run(Unknown Source) ~[?:?]
	at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:151) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:492) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:150) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:49) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.35.65-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.35.65-alpha.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-07 00:57:07 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after -289.244466815s. [closed=[], open=[[buffered_nanos=81782570, waiting_for_connection]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.8.1.jar:?]
	at jdk.proxy2.$Proxy53.run(Unknown Source) ~[?:?]
	at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:151) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:492) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:150) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:49) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.35.65-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.35.65-alpha.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-07 00:57:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1276000 (1 GB)
2022-04-07 00:57:09 source > /airbyte/javabase.sh: line 26:     8 Killed                  /airbyte/bin/"$APPLICATION" "$@"
2022-04-07 00:57:12 source > {"type":"RECORD","record":{"stream":"provider_calc_result","data":{"_id":"621f0b678eeca4be97998b91","calcResultId":1773577,"basicResults":[{"id":"rggR-fjhuE2e1R7fcI_F9Q==","weights":{"weight":1.21329,"weightGross":1.40524,"weightContour":1.21905,"weightContourGross":1.39857},"areas":{"area":0.06182,"areaGross":0.07161,"areaContour":0.06212,"areaContourGross":0.07127},"times":{"time":"00:00:23.1234000","timeGross":"00:00:22.9908000","timeBending":"00:00:00"},"laserResult":{"cuts":8,"cutLength":1425.74}}],"errors":[],"id":"4655d7b6-c1e8-4728-a8db-7ecbd6076aff","nestedPlates":[{"dxfFileId":"_DhYPreVQE-GBOBOfmYaDA==","svgFileId":"NMSl41Hb3kWKLNDuD28r9A==","name":"Plate_4000x2000","length":3995.37158,"width":1986.5293,"minLength":3995.37158,"minWidth":1986.5293,"repeats":3,"times":{"cutting":"00:39:54.2093999","loadUnload":"00:00:00","cleanup":"00:37:19.9865999"},"areas":{"total":7.93692,"used":6.75669,"waste":1.18023,"usedContour":6.77352,"wasteContour":1.1634},"weights":{"total":155.7621,"used":132.60005,"waste":23.16204,"usedContour":132.93042,"wasteContour":22.83167},"laserResult":{"cuts":955,"cutLength":140424.52},"nestingFiles":[{"id":"kh8njQlzLEK9kQuvb4r-Bw==","amount":62,"times":{"time":"00:00:37.6302000","timeGross":"00:00:37.6302000","timeBending":"00:00:00"},"areas":{"area":0.10646,"areaGross":0.12506,"areaContour":0.10672,"areaContourGross":0.12443},"weights":{"weight":2.08928,"weightGross":2.45423,"weightContour":2.09438,"weightContourGross":2.44196}},{"id":"vRVdfn-n00S2-s4zbVvvbA==","amount":1,"times":{"time":"00:00:37.9734000","timeGross":"00:00:37.9734000","timeBending":"00:00:00"},"areas":{"area":0.09434,"areaGross":0.11082,"areaContour":0.09483,"areaContourGross":0.11056},"weights":{"weight":1.85138,"weightGross":2.17477,"weightContour":1.86104,"weightContourGross":2.16983}},{"id":"rggR-fjhuE2e1R7fcI_F9Q==","amount":1,"times":{"time":"00:00:23.1726000","timeGross":"00:00:23.1726000","timeBending":"00:00:00"},"areas":{"area":0.06182,"areaGross":0.07262,"areaContour":0.06212,"areaContourGross":0.07243},"weights":{"weight":1.21329,"weightGross":1.42522,"weightContour":1.21911,"weightContourGross":1.42142}}]},{"dxfFileId":"PsQKwOqyf0OvdEjRgFHEpg==","svgFileId":"mr_99qbHKUmbbaVsDCUoHg==","name":"Plate_4000x2000","length":3963.95557,"width":1974.823,"minLength":3963.95557,"minWidth":1974.823,"repeats":1,"times":{"cutting":"00:44:25.5840000","loadUnload":"00:00:00","cleanup":"00:41:24.9858000"},"areas":{"total":7.82811,"used":6.80267,"waste":1.02544,"usedContour":6.8342,"wasteContour":0.99391},"weights":{"total":153.62666,"used":133.50237,"waste":20.12431,"usedContour":134.12109,"wasteContour":19.50557},"laserResult":{"cuts":1161,"cutLength":152122.11},"nestingFiles":[{"id":"kh8njQlzLEK9kQuvb4r-Bw==","amount":14,"times":{"time":"00:00:37.6847999","timeGross":"00:00:37.6847999","timeBending":"00:00:00"},"areas":{"area":0.10646,"areaGross":0.12251,"areaContour":0.10672,"areaContourGross":0.122},"weights":{"weight":2.08928,"weightGross":2.40422,"weightContour":2.09438,"weightContourGross":2.39418}},{"id":"vRVdfn-n00S2-s4zbVvvbA==","amount":55,"times":{"time":"00:00:38.0286000","timeGross":"00:00:38.0286000","timeBending":"00:00:00"},"areas":{"area":0.09434,"areaGross":0.10856,"areaContour":0.09483,"areaContourGross":0.1084},"weights":{"weight":1.85138,"weightGross":2.13046,"weightContour":1.86104,"weightContourGross":2.12738}},{"id":"rggR-fjhuE2e1R7fcI_F9Q==","amount":2,"times":{"time":"00:00:23.2062000","timeGross":"00:00:23.2062000","timeBending":"00:00:00"},"areas":{"area":0.06182,"areaGross":0.07114,"areaContour":0.06212,"areaContourGross":0.07101},"weights":{"weight":1.21329,"weightGross":1.39618,"weightContour":1.21911,"weightContourGross":1.39361}}]},{"dxfFileId":"j6AvN7ckF0i2yBdcvNgN_w==","svgFileId":"V0zzk-aUekuAqnJK5reGLg==","name":"Plate_4000x2000","length":3912,"width":1997.96887,"minLength":3912,"minWidth":1997.96887,"repeats":1,"times":{"cutting":"00:46:51.2334000","loadUnload":"00:00:00","cleanup":"00:43:09.9852000"},"areas":{"total":7.81605,"used":6.981,"waste":0.83506,"usedContour":7.01775,"wasteContour":0.7983},"weights":{"total":153.39008,"used":137.00206,"waste":16.388,"usedContour":137.7234,"wasteContour":15.66667},"laserResult":{"cuts":1258,"cutLength":159257.19},"nestingFiles":[{"id":"vRVdfn-n00S2-s4zbVvvbA==","amount":74,"times":{"time":"00:00:37.9895999","timeGross":"00:00:37.9895999","timeBending":"00:00:00"},"areas":{"area":0.09434,"areaGross":0.10562,"areaContour":0.09483,"areaContourGross":0.1056},"weights":{"weight":1.85138,"weightGross":2.07284,"weightContour":1.86104,"weightContourGross":2.07244}}]},{"dxfFileId":"Fbn5GdZcEU6G6vTEydXw5w==","svgFileId":"5e1PoVujokeM5dVib5FB8g==","name":"Plate_4000x2000","length":3893.95581,"width":1989.32288,"minLength":3893.95581,"minWidth":1989.32288,"repeats":1,"times":{"cutting":"00:41:21.6438000","loadUnload":"00:00:00","cleanup":"01:02:59.9784000"},"areas":{"total":7.74634,"used":6.67697,"waste":1.06937,"usedContour":6.70863,"wasteContour":1.0377},"weights":{"total":152.02184,"used":131.03546,"waste":20.98637,"usedContour":131.65694,"wasteContour":20.3649},"laserResult":{"cuts":864,"cutLength":153980.72},"nestingFiles":[{"id":"rggR-fjhuE2e1R7fcI_F9Q==","amount":108,"times":{"time":"00:00:22.9781999","timeGross":"00:00:22.9781999","timeBending":"00:00:00"},"areas":{"area":0.06182,"areaGross":0.07173,"areaContour":0.06212,"areaContourGross":0.07136},"weights":{"weight":1.21329,"weightGross":1.40761,"weightContour":1.21911,"weightContourGross":1.40037}}]},{"dxfFileId":"XdqwR0zxDk2zC9wR8E0umA==","svgFileId":"u9wozw7W6UWEB2-Q6MPrLA==","name":"Plate_4000x2000","length":2547,"width":1951.47791,"minLength":2547,"minWidth":1951.47791,"repeats":1,"times":{"cutting":"00:26:47.1888000","loadUnload":"00:00:00","cleanup":"00:40:49.9860000"},"areas":{"total":4.97041,"used":4.32766,"waste":0.64275,"usedContour":4.34819,"wasteContour":0.62223},"weights":{"total":97.54437,"used":84.9304,"waste":12.61398,"usedContour":85.3332,"wasteContour":12.21118},"laserResult":{"cuts":560,"cutLength":99800.39},"nestingFiles":[{"id":"rggR-fjhuE2e1R7fcI_F9Q==","amount":70,"times":{"time":"00:00:22.9596000","timeGross":"00:00:22.9596000","timeBending":"00:00:00"},"areas":{"area":0.06182,"areaGross":0.07101,"areaContour":0.06212,"areaContourGross":0.07068},"weights":{"weight":1.21329,"weightGross":1.39349,"weightContour":1.21911,"weightContourGross":1.38717}}]},{"dxfFileId":"He4HVzyqpUa8pkqI2s4HbA==","svgFileId":"iQClRCihKUailXUBAJKppQ==","name":"Plate_3000x1500","length":2950.91382,"width":1486.0177,"minLength":2950.91382,"minWidth":1486.0177,"repeats":1,"times":{"cutting":"00:24:49.6068000","loadUnload":"00:00:00","cleanup":"00:23:19.9920000"},"areas":{"total":4.38511,"used":3.70848,"waste":0.67663,"usedContour":3.72794,"wasteContour":0.65717},"weights":{"total":86.05778,"used":72.77899,"waste":13.27879,"usedContour":73.16092,"wasteContour":12.89687},"laserResult":{"cuts":662,"cutLength":84632.3},"nestingFiles":[{"id":"vRVdfn-n00S2-s4zbVvvbA==","amount":38,"times":{"time":"00:00:37.9805999","timeGross":"00:00:37.9805999","timeBending":"00:00:00"},"areas":{"area":0.09434,"areaGross":0.11155,"areaContour":0.09483,"areaContourGross":0.11125},"weights":{"weight":1.85138,"weightGross":2.18917,"weightContour":1.86104,"weightContourGross":2.18319}},{"id":"rggR-fjhuE2e1R7fcI_F9Q==","amount":2,"times":{"time":"00:00:23.1768000","timeGross":"00:00:23.1768000","timeBending":"00:00:00"},"areas":{"area":0.06182,"areaGross":0.0731,"areaContour":0.06212,"areaContourGross":0.07288},"weights":{"weight":1.21329,"weightGross":1.43466,"weightContour":1.21911,"weightContourGross":1.4302}}]},{"dxfFileId":"YZuM_bSCzEuh0YWr3epArg==","svgFileId":"U63sb-1pwUifi8qNS6y_PA==","name":"Plate_3000x1500","length":2971.27441,"width":1497.02942,"minLength":2971.27441,"minWidth":1497.0293,"repeats":1,"times":{"cutting":"00:24:44.5056000","loadUnload":"00:00:00","cleanup":"00:26:14.9910000"},"areas":{"total":4.44808,"used":3.75749,"waste":0.69059,"usedContour":3.77679,"wasteContour":0.6713},"weights":{"total":87.29367,"used":73.74075,"waste":13.55292,"usedContour":74.1195,"wasteContour":13.17417},"laserResult":{"cuts":630,"cutLength":
2022-04-07 00:57:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1276090 (1 GB)
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.BigQueryRecordConsumer(close):58 - Started closing all connections
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format.
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_vw_nestedPlates, tmpTable=_airbyte_tmp_dbg_vw_nestedPlates, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_dbg_vw_nestedPlates to the source table _airbyte_raw_vw_nestedPlates.
2022-04-07 00:57:12 destination > 2022-04-07 00:57:12 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_tmp_dbg_vw_nestedPlates}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_raw_vw_nestedPlates}}
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_vw_nestedPlates!
2022-04-07 00:57:14 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $: null found, object expected
2022-04-07 00:57:14 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted.
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables...
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_vw_nestedPlates, tmpTable=_airbyte_tmp_dbg_vw_nestedPlates, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format.
2022-04-07 00:57:14 destination > 2022-04-07 00:57:14 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_offer_position_capable_producers, tmpTable=_airbyte_tmp_fky_offer_position_capable_producers, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-04-07 00:57:14 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation...
2022-04-07 00:57:14 INFO i.a.w.DefaultReplicationWorker(cancel):377 - Cancelling replication worker...
2022-04-07 00:57:15 destination > 2022-04-07 00:57:15 INFO i.a.i.d.b.BigQueryUtils(waitForJobFinish):305 - Waiting for job finish Job{job=JobId{project=lh-data-raw-prod, job=cbc57e2b-e84c-476f-9b65-fdf4b75948f5, location=EU}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1649293034747, endTime=null, startTime=1649293034989, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte@lh-data-raw-prod.iam.gserviceaccount.com, etag=hhp/Oxd5n4LUPAPkSAN1ag==, generatedId=lh-data-raw-prod:EU.cbc57e2b-e84c-476f-9b65-fdf4b75948f5, selfLink=https://www.googleapis.com/bigquery/v2/projects/lh-data-raw-prod/jobs/cbc57e2b-e84c-476f-9b65-fdf4b75948f5?location=EU, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, projectId=lh-data-raw-prod, tableId=_airbyte_tmp_fky_offer_position_capable_producers}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-07 00:57:17 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.host: is missing but it is required, $.port: is missing but it is required, $.instance: does not have a value in the enumeration [standalone]
2022-04-07 00:57:17 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.server_addresses: is missing but it is required, $.instance: does not have a value in the enumeration [replica]
2022-04-07 00:57:19 destination > 2022-04-07 00:57:19 INFO i.a.i.d.b.BigQueryUtils(waitForJobFinish):307 - Job finish Job{job=JobId{project=lh-data-raw-prod, job=cbc57e2b-e84c-476f-9b65-fdf4b75948f5, location=EU}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1649293034747, endTime=null, startTime=1649293034989, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte@lh-data-raw-prod.iam.gserviceaccount.com, etag=hhp/Oxd5n4LUPAPkSAN1ag==, generatedId=lh-data-raw-prod:EU.cbc57e2b-e84c-476f-9b65-fdf4b75948f5, selfLink=https://www.googleapis.com/bigquery/v2/projects/lh-data-raw-prod/jobs/cbc57e2b-e84c-476f-9b65-fdf4b75948f5?location=EU, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, projectId=lh-data-raw-prod, tableId=_airbyte_tmp_fky_offer_position_capable_producers}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-07 00:57:19 destination > 2022-04-07 00:57:19 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_fky_offer_position_capable_producers to the source table _airbyte_raw_offer_position_capable_producers.
2022-04-07 00:57:19 destination > 2022-04-07 00:57:19 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_tmp_fky_offer_position_capable_producers}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, tableId=_airbyte_raw_offer_position_capable_producers}}
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_offer_position_capable_producers!
2022-04-07 00:57:21 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $: null found, object expected
2022-04-07 00:57:21 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted.
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables...
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_offer_position_capable_producers, tmpTable=_airbyte_tmp_fky_offer_position_capable_producers, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format.
2022-04-07 00:57:21 destination > 2022-04-07 00:57:21 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_provider_calc_result, tmpTable=_airbyte_tmp_csm_provider_calc_result, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-04-07 00:57:22 destination > 2022-04-07 00:57:22 INFO i.a.i.d.b.BigQueryUtils(waitForJobFinish):305 - Waiting for job finish Job{job=JobId{project=lh-data-raw-prod, job=4a561c2e-1f13-4102-bc47-f32d37bcf3d9, location=EU}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1649293042137, endTime=null, startTime=1649293042415, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=airbyte@lh-data-raw-prod.iam.gserviceaccount.com, etag=HcRqPxv/7TPHE4CBOCqAuQ==, generatedId=lh-data-raw-prod:EU.4a561c2e-1f13-4102-bc47-f32d37bcf3d9, selfLink=https://www.googleapis.com/bigquery/v2/projects/lh-data-raw-prod/jobs/4a561c2e-1f13-4102-bc47-f32d37bcf3d9?location=EU, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=mongodb, projectId=lh-data-raw-prod, tableId=_airbyte_tmp_csm_provider_calc_result}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null}
2022-04-07 00:57:24 INFO i.a.w.DefaultReplicationWorker(cancel):385 - Cancelling destination...
2022-04-07 00:57:24 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-04-07 00:57:24 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-04-07 00:57:25 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-04-07 00:57:25 INFO i.a.w.DefaultReplicationWorker(cancel):392 - Cancelling source...
2022-04-07 00:57:25 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-04-07 00:57:25 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-04-07 00:57:25 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-04-07 00:57:25 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread...
2022-04-07 00:57:25 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 137
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 137. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 143. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 137
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-07 00:57:25 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future...
2022-04-07 00:57:25 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled.
2022-04-07 00:57:25 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled.
2022-04-07 00:57:25 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-07 00:57:25 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-07 00:57:25 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=67be4ec8-20fc-30c9-93f2-12ca78486c5d, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:106) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:53) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2022-04-07 00:57:25 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1f5aa99d[status=cancelled,recordsSynced=1276090,bytesSynced=1207657972,startTime=1649290304672,endTime=1649293045306,totalStats=io.airbyte.config.SyncStats@4edc492a[recordsEmitted=1276090,bytesEmitted=1207657972,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@9f55f43[streamName=provider_calc_result,stats=io.airbyte.config.SyncStats@79a9e491[recordsEmitted=1239385,bytesEmitted=1163765207,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@33f5bc78[streamName=offer_position_capable_producers,stats=io.airbyte.config.SyncStats@1f4c3635[recordsEmitted=36705,bytesEmitted=43892765,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-07 00:57:25 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-07 00:57:25 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@3c607dd8[state={}]