2022-05-23 08:25:08 INFO () WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2022-05-23 08:25:08 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2022-05-23 08:25:08 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2022-05-23 08:25:08 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-23 08:25:08 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2022-05-23 08:25:08 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 11619 attempt id: 0
2022-05-23 08:25:08 INFO () DefaultReplicationWorker(run):91 - configured sync modes: {kobold_production.transactions=full_refresh - overwrite}
2022-05-23 08:25:08 INFO () DefaultAirbyteDestination(start):64 - Running destination...
2022-05-23 08:25:08 INFO () LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.18 exists...
2022-05-23 08:25:08 INFO () LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.18 was found locally.
2022-05-23 08:25:08 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/11619/0 --network host --log-driver none airbyte/destination-postgres:0.3.18 write --config destination_config.json --catalog destination_catalog.json
2022-05-23 08:25:08 INFO () LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.13 exists...
2022-05-23 08:25:08 INFO () LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.13 was found locally.
2022-05-23 08:25:08 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/11619/0 --network host --log-driver none airbyte/source-mongodb-v2:0.1.13 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-05-23 08:25:08 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started.
2022-05-23 08:25:08 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join.
2022-05-23 08:25:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started.
destination - 2022-05-23 08:25:09 ERROR () LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
destination - 2022-05-23 08:25:09 ERROR () LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
destination - 2022-05-23 08:25:09 ERROR () LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
destination - 2022-05-23 08:25:09 ERROR () LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
destination - 2022-05-23 08:25:09 ERROR () LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
source - 2022-05-23 08:25:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:10 INFO i.a.i.s.m.MongoDbSource(main):64 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource
destination - 2022-05-23 08:25:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:10 INFO i.a.i.d.p.PostgresDestination(main):77 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 4550d6965deb438886f9a9151a90d50c
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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'}
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='transactions', namespace='kobold_production'}, New Cursor Field: null. Resetting cursor value
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 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
destination - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[127.0.0.1:27017], srvHost=kobold-production-clust.qcfo6.mongodb.net, mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='atlas-1411wg-shard-0'}
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017 to client view of cluster
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017 to client view of cluster
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017 to client view of cluster
source - 2022-05-23 08:25:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:11 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@6719a5b8 from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
destination - 2022-05-23 08:25:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:12 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
destination - 2022-05-23 08:25:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:12 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=transactions, namespace=kobold_production, outputSchemaName=kobold_production, tmpTableName=_airbyte_tmp_djb_transactions, outputTableName=_airbyte_raw_transactions, syncMode=overwrite}
destination - 2022-05-23 08:25:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:12 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
destination - 2022-05-23 08:25:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:12 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams
destination - 2022-05-23 08:25:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:12 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream transactions. schema: kobold_production, tmp table name: _airbyte_tmp_djb_transactions
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:5, serverValue:203183}] to kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:151743}] to kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:4, serverValue:151068}] to kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:151067}] to kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:151742}] to kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:6, serverValue:203182}] to kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=586686549, setName='atlas-1411wg-shard-0', canonicalAddress=kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, hosts=[kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017], passives=[], arbiters=[], primary='kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='GCP'}, Tag{name='region', value='ASIA_SOUTHEAST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=2, topologyVersion=TopologyVersion{processId=628141726c4315798a426a2c, counter=4}, lastWriteDate=Mon May 23 08:25:11 UTC 2022, lastUpdateTimeNanos=1047236455966259}
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=577805437, setName='atlas-1411wg-shard-0', canonicalAddress=kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017, hosts=[kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017], passives=[], arbiters=[], primary='kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='GCP'}, Tag{name='region', value='ASIA_SOUTHEAST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=7fffffff0000000000000011, setVersion=2, topologyVersion=TopologyVersion{processId=628141e379f0833b3df4214d, counter=6}, lastWriteDate=Mon May 23 08:25:11 UTC 2022, lastUpdateTimeNanos=1047236449486548}
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=582543290, setName='atlas-1411wg-shard-0', canonicalAddress=kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, hosts=[kobold-production-clust-shard-00-00.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-01.qcfo6.mongodb.net:27017, kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017], passives=[], arbiters=[], primary='kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='GCP'}, Tag{name='region', value='ASIA_SOUTHEAST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=2, topologyVersion=TopologyVersion{processId=6281428d519fc5d22a481af1, counter=3}, lastWriteDate=Mon May 23 08:25:11 UTC 2022, lastUpdateTimeNanos=1047236453741400}
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max election id to 7fffffff0000000000000011 from replica set primary kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max set version to 2 from replica set primary kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
source - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:7, serverValue:203184}] to kobold-production-clust-shard-00-02.qcfo6.mongodb.net:27017
destination - 2022-05-23 08:25:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:13 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed.
2022-05-23 08:25:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 1000
2022-05-23 08:25:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 2000
2022-05-23 08:25:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 3000
2022-05-23 08:25:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 4000
2022-05-23 08:25:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 5000
2022-05-23 08:25:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 6000
destination - 2022-05-23 08:25:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:39 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6710 records (24 MB)
2022-05-23 08:25:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 7000
2022-05-23 08:25:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 8000
2022-05-23 08:25:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 9000
source - 2022-05-23 08:25:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:41 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 10000
2022-05-23 08:25:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 10000
2022-05-23 08:25:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 11000
2022-05-23 08:25:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 12000
destination - 2022-05-23 08:25:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:42 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5946 records (24 MB)
2022-05-23 08:25:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 13000
2022-05-23 08:25:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 14000
2022-05-23 08:25:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 15000
2022-05-23 08:25:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 16000
2022-05-23 08:25:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 17000
2022-05-23 08:25:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 18000
destination - 2022-05-23 08:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:45 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5986 records (24 MB)
2022-05-23 08:25:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 19000
source - 2022-05-23 08:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:45 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 20000
2022-05-23 08:25:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 20000
2022-05-23 08:25:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 21000
2022-05-23 08:25:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 22000
2022-05-23 08:25:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 23000
2022-05-23 08:25:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 24000
destination - 2022-05-23 08:25:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:46 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5823 records (24 MB)
2022-05-23 08:25:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 25000
2022-05-23 08:25:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 26000
2022-05-23 08:25:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 27000
2022-05-23 08:25:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 28000
2022-05-23 08:25:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 29000
source - 2022-05-23 08:25:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 30000
2022-05-23 08:25:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 30000
destination - 2022-05-23 08:25:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:48 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6138 records (24 MB)
2022-05-23 08:25:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 31000
2022-05-23 08:25:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 32000
2022-05-23 08:25:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 33000
2022-05-23 08:25:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 34000
2022-05-23 08:25:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 35000
2022-05-23 08:25:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 36000
destination - 2022-05-23 08:25:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:50 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6245 records (24 MB)
2022-05-23 08:25:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 37000
2022-05-23 08:25:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 38000
2022-05-23 08:25:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 39000
source - 2022-05-23 08:25:51 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:51 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 40000
2022-05-23 08:25:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 40000
2022-05-23 08:25:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 41000
2022-05-23 08:25:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 42000
destination - 2022-05-23 08:25:52 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:52 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5820 records (24 MB)
2022-05-23 08:25:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 43000
2022-05-23 08:25:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 44000
2022-05-23 08:25:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 45000
2022-05-23 08:25:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 46000
2022-05-23 08:25:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 47000
2022-05-23 08:25:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 48000
destination - 2022-05-23 08:25:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:54 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5747 records (24 MB)
2022-05-23 08:25:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 49000
source - 2022-05-23 08:25:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 50000
2022-05-23 08:25:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 50000
2022-05-23 08:25:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 51000
2022-05-23 08:25:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 52000
2022-05-23 08:25:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 53000
2022-05-23 08:25:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 54000
destination - 2022-05-23 08:25:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:55 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5830 records (24 MB)
2022-05-23 08:25:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 55000
2022-05-23 08:25:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 56000
2022-05-23 08:25:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 57000
2022-05-23 08:25:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 58000
2022-05-23 08:25:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 59000
source - 2022-05-23 08:25:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 60000
2022-05-23 08:25:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 60000
destination - 2022-05-23 08:25:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:57 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6189 records (24 MB)
2022-05-23 08:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 61000
2022-05-23 08:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 62000
2022-05-23 08:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 63000
2022-05-23 08:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 64000
2022-05-23 08:25:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 65000
2022-05-23 08:25:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 66000
destination - 2022-05-23 08:25:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:25:59 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6020 records (24 MB)
2022-05-23 08:25:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 67000
2022-05-23 08:26:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 68000
2022-05-23 08:26:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 69000
source - 2022-05-23 08:26:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 70000
2022-05-23 08:26:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 70000
2022-05-23 08:26:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 71000
2022-05-23 08:26:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 72000
destination - 2022-05-23 08:26:01 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:01 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6177 records (24 MB)
2022-05-23 08:26:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 73000
2022-05-23 08:26:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 74000
2022-05-23 08:26:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 75000
2022-05-23 08:26:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 76000
2022-05-23 08:26:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 77000
2022-05-23 08:26:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 78000
destination - 2022-05-23 08:26:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:02 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6267 records (24 MB)
2022-05-23 08:26:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 79000
source - 2022-05-23 08:26:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 80000
2022-05-23 08:26:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 80000
2022-05-23 08:26:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 81000
2022-05-23 08:26:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 82000
2022-05-23 08:26:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 83000
2022-05-23 08:26:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 84000
2022-05-23 08:26:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 85000
destination - 2022-05-23 08:26:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:05 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6241 records (24 MB)
2022-05-23 08:26:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 86000
2022-05-23 08:26:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 87000
2022-05-23 08:26:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 88000
2022-05-23 08:26:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 89000
source - 2022-05-23 08:26:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 90000
2022-05-23 08:26:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 90000
2022-05-23 08:26:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 91000
destination - 2022-05-23 08:26:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:06 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6278 records (24 MB)
2022-05-23 08:26:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 92000
2022-05-23 08:26:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 93000
2022-05-23 08:26:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 94000
2022-05-23 08:26:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 95000
2022-05-23 08:26:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 96000
2022-05-23 08:26:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 97000
destination - 2022-05-23 08:26:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6050 records (24 MB)
2022-05-23 08:26:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 98000
2022-05-23 08:26:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 99000
source - 2022-05-23 08:26:09 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 100000
2022-05-23 08:26:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 100000
2022-05-23 08:26:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 101000
2022-05-23 08:26:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 102000
2022-05-23 08:26:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 103000
destination - 2022-05-23 08:26:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6247 records (24 MB)
2022-05-23 08:26:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 104000
2022-05-23 08:26:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 105000
2022-05-23 08:26:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 106000
2022-05-23 08:26:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 107000
2022-05-23 08:26:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 108000
2022-05-23 08:26:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 109000
destination - 2022-05-23 08:26:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:12 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 5994 records (24 MB)
source - 2022-05-23 08:26:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 110000
2022-05-23 08:26:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 110000
2022-05-23 08:26:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 111000
2022-05-23 08:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 112000
2022-05-23 08:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 113000
2022-05-23 08:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 114000
2022-05-23 08:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 115000
2022-05-23 08:26:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 116000
destination - 2022-05-23 08:26:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:13 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6467 records (24 MB)
2022-05-23 08:26:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 117000
2022-05-23 08:26:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 118000
2022-05-23 08:26:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 119000
source - 2022-05-23 08:26:15 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 120000
2022-05-23 08:26:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 120000
2022-05-23 08:26:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 121000
2022-05-23 08:26:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 122000
destination - 2022-05-23 08:26:15 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:15 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6235 records (24 MB)
2022-05-23 08:26:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 123000
2022-05-23 08:26:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 124000
2022-05-23 08:26:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 125000
2022-05-23 08:26:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 126000
2022-05-23 08:26:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 127000
2022-05-23 08:26:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 128000
destination - 2022-05-23 08:26:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:17 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6202 records (24 MB)
2022-05-23 08:26:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 129000
source - 2022-05-23 08:26:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:17 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 130000
2022-05-23 08:26:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 130000
2022-05-23 08:26:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 131000
2022-05-23 08:26:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 132000
2022-05-23 08:26:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 133000
2022-05-23 08:26:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 134000
2022-05-23 08:26:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 135000
destination - 2022-05-23 08:26:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:19 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6400 records (24 MB)
2022-05-23 08:26:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 136000
2022-05-23 08:26:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 137000
2022-05-23 08:26:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 138000
2022-05-23 08:26:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 139000
source - 2022-05-23 08:26:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 140000
2022-05-23 08:26:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 140000
2022-05-23 08:26:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 141000
destination - 2022-05-23 08:26:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:20 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6473 records (24 MB)
2022-05-23 08:26:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 142000
2022-05-23 08:26:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 143000
2022-05-23 08:26:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 144000
2022-05-23 08:26:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 145000
2022-05-23 08:26:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 146000
2022-05-23 08:26:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 147000
destination - 2022-05-23 08:26:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:22 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6377 records (24 MB)
2022-05-23 08:26:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 148000
2022-05-23 08:26:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 149000
source - 2022-05-23 08:26:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 150000
2022-05-23 08:26:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 150000
2022-05-23 08:26:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 151000
2022-05-23 08:26:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 152000
2022-05-23 08:26:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 153000
2022-05-23 08:26:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 154000
destination - 2022-05-23 08:26:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:24 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6350 records (24 MB)
2022-05-23 08:26:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 155000
2022-05-23 08:26:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 156000
2022-05-23 08:26:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 157000
2022-05-23 08:26:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 158000
2022-05-23 08:26:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 159000
source - 2022-05-23 08:26:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 160000
2022-05-23 08:26:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 160000
destination - 2022-05-23 08:26:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:26 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6507 records (24 MB)
2022-05-23 08:26:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 161000
2022-05-23 08:26:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 162000
2022-05-23 08:26:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 163000
2022-05-23 08:26:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 164000
2022-05-23 08:26:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 165000
2022-05-23 08:26:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 166000
2022-05-23 08:26:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 167000
destination - 2022-05-23 08:26:28 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:28 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6613 records (24 MB)
2022-05-23 08:26:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 168000
2022-05-23 08:26:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 169000
source - 2022-05-23 08:26:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 170000
2022-05-23 08:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 170000
2022-05-23 08:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 171000
2022-05-23 08:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 172000
2022-05-23 08:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 173000
destination - 2022-05-23 08:26:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6373 records (24 MB)
2022-05-23 08:26:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 174000
2022-05-23 08:26:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 175000
2022-05-23 08:26:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 176000
2022-05-23 08:26:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 177000
2022-05-23 08:26:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 178000
2022-05-23 08:26:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 179000
source - 2022-05-23 08:26:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 180000
2022-05-23 08:26:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 180000
destination - 2022-05-23 08:26:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:31 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6695 records (24 MB)
2022-05-23 08:26:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 181000
2022-05-23 08:26:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 182000
2022-05-23 08:26:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 183000
2022-05-23 08:26:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 184000
2022-05-23 08:26:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 185000
2022-05-23 08:26:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 186000
destination - 2022-05-23 08:26:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:33 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6421 records (24 MB)
2022-05-23 08:26:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 187000
2022-05-23 08:26:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 188000
2022-05-23 08:26:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 189000
source - 2022-05-23 08:26:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:34 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 190000
2022-05-23 08:26:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 190000
2022-05-23 08:26:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 191000
2022-05-23 08:26:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 192000
2022-05-23 08:26:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 193000
destination - 2022-05-23 08:26:35 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:35 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6600 records (24 MB)
2022-05-23 08:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 194000
2022-05-23 08:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 195000
2022-05-23 08:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 196000
2022-05-23 08:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 197000
2022-05-23 08:26:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 198000
2022-05-23 08:26:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 199000
source - 2022-05-23 08:26:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 200000
2022-05-23 08:26:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 200000
destination - 2022-05-23 08:26:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:37 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6567 records (24 MB)
2022-05-23 08:26:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 201000
2022-05-23 08:26:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 202000
2022-05-23 08:26:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 203000
2022-05-23 08:26:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 204000
2022-05-23 08:26:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 205000
2022-05-23 08:26:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 206000
destination - 2022-05-23 08:26:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:39 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6671 records (24 MB)
2022-05-23 08:26:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 207000
2022-05-23 08:26:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 208000
2022-05-23 08:26:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 209000
source - 2022-05-23 08:26:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 210000
2022-05-23 08:26:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 210000
2022-05-23 08:26:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 211000
2022-05-23 08:26:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 212000
destination - 2022-05-23 08:26:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:41 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6298 records (24 MB)
2022-05-23 08:26:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 213000
2022-05-23 08:26:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 214000
2022-05-23 08:26:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 215000
2022-05-23 08:26:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 216000
2022-05-23 08:26:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 217000
2022-05-23 08:26:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 218000
2022-05-23 08:26:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 219000
destination - 2022-05-23 08:26:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:43 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6359 records (24 MB)
source - 2022-05-23 08:26:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:42 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 220000
2022-05-23 08:26:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 220000
2022-05-23 08:26:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 221000
2022-05-23 08:26:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 222000
2022-05-23 08:26:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 223000
2022-05-23 08:26:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 224000
2022-05-23 08:26:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 225000
destination - 2022-05-23 08:26:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:44 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6536 records (24 MB)
2022-05-23 08:26:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 226000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 227000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 228000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 229000
source - 2022-05-23 08:26:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:45 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 230000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 230000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 231000
2022-05-23 08:26:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 232000
destination - 2022-05-23 08:26:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:46 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6534 records (24 MB)
2022-05-23 08:26:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 233000
2022-05-23 08:26:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 234000
2022-05-23 08:26:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 235000
2022-05-23 08:26:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 236000
2022-05-23 08:26:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 237000
2022-05-23 08:26:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 238000
2022-05-23 08:26:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 239000
destination - 2022-05-23 08:26:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:47 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6574 records (24 MB)
source - 2022-05-23 08:26:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 240000
2022-05-23 08:26:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 240000
2022-05-23 08:26:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 241000
2022-05-23 08:26:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 242000
2022-05-23 08:26:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 243000
2022-05-23 08:26:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 244000
2022-05-23 08:26:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 245000
destination - 2022-05-23 08:26:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:49 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6634 records (24 MB)
2022-05-23 08:26:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 246000
2022-05-23 08:26:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 247000
2022-05-23 08:26:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 248000
2022-05-23 08:26:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 249000
source - 2022-05-23 08:26:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 250000
2022-05-23 08:26:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 250000
2022-05-23 08:26:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 251000
2022-05-23 08:26:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 252000
destination - 2022-05-23 08:26:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:50 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6424 records (24 MB)
2022-05-23 08:26:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 253000
2022-05-23 08:26:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 254000
2022-05-23 08:26:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 255000
2022-05-23 08:26:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 256000
2022-05-23 08:26:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 257000
2022-05-23 08:26:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 258000
destination - 2022-05-23 08:26:52 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:52 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6104 records (24 MB)
2022-05-23 08:26:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 259000
source - 2022-05-23 08:26:52 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:52 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 260000
2022-05-23 08:26:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 260000
2022-05-23 08:26:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 261000
2022-05-23 08:26:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 262000
2022-05-23 08:26:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 263000
2022-05-23 08:26:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 264000
destination - 2022-05-23 08:26:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:53 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6586 records (24 MB)
2022-05-23 08:26:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 265000
2022-05-23 08:26:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 266000
2022-05-23 08:26:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 267000
2022-05-23 08:26:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 268000
2022-05-23 08:26:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 269000
source - 2022-05-23 08:26:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:55 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 270000
2022-05-23 08:26:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 270000
destination - 2022-05-23 08:26:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:55 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6131 records (24 MB)
2022-05-23 08:26:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 271000
2022-05-23 08:26:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 272000
2022-05-23 08:26:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 273000
2022-05-23 08:26:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 274000
2022-05-23 08:26:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 275000
2022-05-23 08:26:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 276000
2022-05-23 08:26:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 277000
destination - 2022-05-23 08:26:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:56 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6438 records (24 MB)
2022-05-23 08:26:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 278000
2022-05-23 08:26:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 279000
source - 2022-05-23 08:26:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 280000
2022-05-23 08:26:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 280000
2022-05-23 08:26:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 281000
2022-05-23 08:26:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 282000
2022-05-23 08:26:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 283000
destination - 2022-05-23 08:26:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:58 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6595 records (24 MB)
2022-05-23 08:26:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 284000
2022-05-23 08:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 285000
2022-05-23 08:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 286000
2022-05-23 08:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 287000
2022-05-23 08:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 288000
2022-05-23 08:26:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 289000
source - 2022-05-23 08:27:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:26:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 290000
2022-05-23 08:27:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 290000
destination - 2022-05-23 08:27:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:00 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6166 records (24 MB)
2022-05-23 08:27:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 291000
2022-05-23 08:27:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 292000
2022-05-23 08:27:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 293000
2022-05-23 08:27:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 294000
2022-05-23 08:27:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 295000
2022-05-23 08:27:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 296000
destination - 2022-05-23 08:27:01 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:01 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6362 records (24 MB)
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 297000
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 298000
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 299000
source - 2022-05-23 08:27:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 300000
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 300000
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 301000
2022-05-23 08:27:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 302000
destination - 2022-05-23 08:27:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:03 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6361 records (24 MB)
2022-05-23 08:27:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 303000
2022-05-23 08:27:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 304000
2022-05-23 08:27:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 305000
2022-05-23 08:27:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 306000
2022-05-23 08:27:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 307000
2022-05-23 08:27:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 308000
2022-05-23 08:27:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 309000
destination - 2022-05-23 08:27:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6759 records (24 MB)
source - 2022-05-23 08:27:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 310000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 310000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 311000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 312000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 313000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 314000
2022-05-23 08:27:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 315000
2022-05-23 08:27:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 316000
destination - 2022-05-23 08:27:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:06 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6750 records (24 MB)
2022-05-23 08:27:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 317000
2022-05-23 08:27:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 318000
2022-05-23 08:27:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 319000
source - 2022-05-23 08:27:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 320000
2022-05-23 08:27:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 320000
2022-05-23 08:27:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 321000
2022-05-23 08:27:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 322000
2022-05-23 08:27:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 323000
destination - 2022-05-23 08:27:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:07 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6818 records (24 MB)
2022-05-23 08:27:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 324000
2022-05-23 08:27:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 325000
2022-05-23 08:27:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 326000
2022-05-23 08:27:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 327000
2022-05-23 08:27:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 328000
2022-05-23 08:27:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 329000
destination - 2022-05-23 08:27:09 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:09 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6712 records (24 MB)
source - 2022-05-23 08:27:09 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 330000
2022-05-23 08:27:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 330000
2022-05-23 08:27:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 331000
2022-05-23 08:27:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 332000
2022-05-23 08:27:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 333000
2022-05-23 08:27:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 334000
2022-05-23 08:27:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 335000
2022-05-23 08:27:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 336000
destination - 2022-05-23 08:27:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6483 records (24 MB)
2022-05-23 08:27:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 337000
2022-05-23 08:27:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 338000
2022-05-23 08:27:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 339000
source - 2022-05-23 08:27:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 340000
2022-05-23 08:27:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 340000
2022-05-23 08:27:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 341000
2022-05-23 08:27:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 342000
2022-05-23 08:27:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 343000
destination - 2022-05-23 08:27:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:12 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6855 records (24 MB)
2022-05-23 08:27:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 344000
2022-05-23 08:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 345000
2022-05-23 08:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 346000
2022-05-23 08:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 347000
2022-05-23 08:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 348000
2022-05-23 08:27:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 349000
destination - 2022-05-23 08:27:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6612 records (24 MB)
source - 2022-05-23 08:27:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 350000
2022-05-23 08:27:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 350000
2022-05-23 08:27:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 351000
2022-05-23 08:27:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 352000
2022-05-23 08:27:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 353000
2022-05-23 08:27:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 354000
2022-05-23 08:27:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 355000
2022-05-23 08:27:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 356000
destination - 2022-05-23 08:27:15 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:15 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6807 records (24 MB)
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 357000
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 358000
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 359000
source - 2022-05-23 08:27:16 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream transactions. Records read: 360000
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 360000
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 361000
2022-05-23 08:27:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 362000
2022-05-23 08:27:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 363000
destination - 2022-05-23 08:27:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:17 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 6712 records (24 MB)
2022-05-23 08:27:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 364000
2022-05-23 08:27:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 365000
2022-05-23 08:27:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 366000
2022-05-23 08:27:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 367000
2022-05-23 08:27:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 368000
source - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
source - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
source - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.source.mongodb.MongoDbSource
source - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.s.m.MongoDbSource(main):66 - completed source: class io.airbyte.integrations.source.mongodb.MongoDbSource
2022-05-23 08:27:18 INFO () DefaultReplicationWorker(run):121 - Source thread complete.
2022-05-23 08:27:18 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join.
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing transactions: 4875 records (17 MB)
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - Finalizing tables in destination started for 1 streams
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):166 - Finalizing stream transactions. schema kobold_production, tmp table _airbyte_tmp_djb_transactions, final table _airbyte_raw_transactions
destination - 2022-05-23 08:27:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:18 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):179 - Executing finalization of tables.
destination - 2022-05-23 08:27:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:30 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Finalizing tables in destination completed.
destination - 2022-05-23 08:27:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:30 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):184 - Cleaning tmp tables in destination started for 1 streams
destination - 2022-05-23 08:27:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:30 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):188 - Cleaning tmp table in destination started for stream transactions. schema kobold_production, tmp table name: _airbyte_tmp_djb_transactions
destination - 2022-05-23 08:27:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):193 - Cleaning tmp tables in destination completed.
destination - 2022-05-23 08:27:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:31 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
destination - 2022-05-23 08:27:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-23 08:27:31 INFO i.a.i.d.p.PostgresDestination(main):79 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-05-23 08:27:31 INFO () DefaultReplicationWorker(run):124 - Destination thread complete.
2022-05-23 08:27:31 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@20de4318[status=completed,recordsSynced=368144,bytesSynced=379143775,startTime=1653294308202,endTime=1653294451334]
2022-05-23 08:27:31 INFO () DefaultReplicationWorker(run):161 - Source did not output any state messages
2022-05-23 08:27:31 WARN () DefaultReplicationWorker(run):169 - State capture: No new state, falling back on input state: io.airbyte.config.State@38dc9399[state={}]
2022-05-23 08:27:31 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2022-05-23 08:27:31 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):233 - sync summary: io.airbyte.config.StandardSyncOutput@2dfa0992[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2808c73f[status=completed,recordsSynced=368144,bytesSynced=379143775,startTime=1653294308202,endTime=1653294451334],state=io.airbyte.config.State@38dc9399[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@407d76e1[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@54ff754d[stream=io.airbyte.protocol.models.AirbyteStream@29b450d9[name=transactions,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"buyer":{"type":"string"},"notes":{"type":"string"},"phone":{"type":"string"},"price":{"type":"number"},"paidAt":{"type":"string"},"source":{"type":"string"},"address":{"type":"string"},"channel":{"type":"string"},"bankType":{"type":"string"},"logistic":{"type":"string"},"accountID":{"type":"string"},"bankAsset":{"type":"string"},"contactID":{"type":"string"},"createdAt":{"type":"number"},"invoiceNo":{"type":"string"},"updatedAt":{"type":"number"},"voucherID":{"type":"string"},"skipUpdate":{"type":"boolean"},"deliveryFee":{"type":"number"},"forceUpdate":{"type":"boolean"},"itemDetails":{"type":"string"},"channelAsset":{"type":"string"},"latestStatus":{"type":"string"},"payingMethod":{"type":"string"},"bankAccountNo":{"type":"string"},"logisticAsset":{"type":"string"},"transactionNo":{"type":"string"},"additionalData":{"type":"string"},"channelAccount":{"type":"string"},"bankAccountName":{"type":"string"},"paymentMethodV2":{"type":"string"},"transactionDetails":{"type":"string"},"total_aibyte_transform":{"type":"string"},"discount_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=kobold_production,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2022-05-23 08:27:31 INFO () ConfigRepository(updateConnectionState):453 - Updating connection 144ae874-ee92-4a16-911f-e197377c8477 state: io.airbyte.config.State@43f0b25c[state={}]
2022-05-23 08:27:31 INFO () DatabaseConfigPersistence(updateConfigRecord):236 - Updating STANDARD_SYNC_STATE record 144ae874-ee92-4a16-911f-e197377c8477
2022-05-23 08:27:31 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2022-05-23 08:27:31 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2022-05-23 08:27:31 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-23 08:27:31 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2022-05-23 08:27:31 INFO () DefaultNormalizationWorker(run):46 - Running normalization.
2022-05-23 08:27:31 INFO () DefaultNormalizationRunner(runProcess):114 - Running with normalization version: airbyte/normalization:0.1.58
2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.58 exists...
2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - airbyte/normalization:0.1.58 was found locally.
2022-05-23 08:27:31 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/11619/0/normalize --network host --log-driver none airbyte/normalization:0.1.58 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - Running: transform-config --config destination_config.json --integration-type postgres --out /data/11619/0/normalize
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - Namespace(config='destination_config.json', integration_type=<DestinationType.postgres: 'postgres'>, out='/data/11619/0/normalize')
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - transform_postgres
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - Running: transform-catalog --integration-type postgres --profile-config-dir /data/11619/0/normalize --catalog destination_catalog.json --out /data/11619/0/normalize/models/generated/ --json-column _airbyte_data
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - Processing destination_catalog.json...
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/kobold_production/transactions_ab1.sql from transactions
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/kobold_production/transactions_ab2.sql from transactions
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/kobold_production/transactions_ab3.sql from transactions
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 -   Generating airbyte_tables/kobold_production/transactions.sql from transactions
normalization - 2022-05-23 08:27:31 INFO () LineGobbler(voidCall):82 - detected no config file for ssh, assuming ssh is off.
normalization - 2022-05-23 08:27:33 INFO () LineGobbler(voidCall):82 - Running with dbt=0.21.0
normalization - 2022-05-23 08:27:33 INFO () LineGobbler(voidCall):82 - Unable to do partial parsing because ../build/partial_parse.msgpack not found
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - There are 2 unused configuration paths:
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_incremental
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_views
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - 
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - Found 4 models, 0 tests, 0 snapshots, 0 analyses, 478 macros, 0 operations, 0 seed files, 1 source, 0 exposures
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - 
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - 08:27:35 | Concurrency: 32 threads (target='prod')
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - 08:27:35 | 
normalization - 2022-05-23 08:27:35 INFO () LineGobbler(voidCall):82 - 08:27:35 | 1 of 1 START table model kobold_production.transactions...................................................... [RUN]
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - 08:28:20 | 1 of 1 OK created table model kobold_production.transactions................................................. [SELECT 368144 in 45.17s]
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - 08:28:20 | 
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - 08:28:20 | Finished running 1 table model in 45.48s.
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - 
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - Completed successfully
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - 
normalization - 2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2022-05-23 08:28:20 INFO () DefaultNormalizationWorker(run):69 - Normalization executed in 49 seconds.
2022-05-23 08:28:20 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2022-05-23 08:28:20 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.30.34-alpha
2022-05-23 08:28:20 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2022-05-23 08:28:20 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-23 08:28:20 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2022-05-23 08:28:20 INFO () DbtTransformationWorker(run):44 - Running dbt transformation.
2022-05-23 08:28:20 INFO () DefaultNormalizationRunner(runProcess):114 - Running with normalization version: airbyte/normalization:0.1.58
2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.58 exists...
2022-05-23 08:28:20 INFO () LineGobbler(voidCall):82 - airbyte/normalization:0.1.58 was found locally.
2022-05-23 08:28:20 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/11619/0/transform --network host --log-driver none airbyte/normalization:0.1.58 configure-dbt --integration-type postgres --config destination_config.json --git-repo https://airbyte:cCMh2szhpr52Up6ynF8F@gl.kokatto.net/koala/koala-data-dbt/koala-data-dbt
normalization - 2022-05-23 08:28:21 INFO () LineGobbler(voidCall):82 - Running: git clone --depth 5 --single-branch  $GIT_REPO git_repo
normalization - 2022-05-23 08:28:21 ERROR () LineGobbler(voidCall):82 - Cloning into 'git_repo'...
normalization - 2022-05-23 08:28:22 ERROR () LineGobbler(voidCall):82 - warning: redirecting to https://gl.kokatto.net/koala/koala-data-dbt/koala-data-dbt.git/
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Last 5 commits in git_repo:
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - 0f8f66d rename TRANSACTIONS
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - 3a13c35 rename schema yml
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - b226a9d update schema
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - af84689 cast discount to integer
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - 04ec1eb cast discount to numeric
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - /data/11619/0/transform
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Running: transform-config --config destination_config.json --integration-type postgres --out /data/11619/0/transform
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Namespace(config='destination_config.json', integration_type=<DestinationType.postgres: 'postgres'>, out='/data/11619/0/transform')
normalization - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - transform_postgres
2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Checking if fishtownanalytics/dbt:0.19.1 exists...
2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - fishtownanalytics/dbt:0.19.1 was found locally.
2022-05-23 08:28:24 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/11619/0/transform --network host --log-driver none --entrypoint /bin/bash fishtownanalytics/dbt:0.19.1 entrypoint.sh run
dbt - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Running from /data/11619/0/transform/git_repo
dbt - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - detected no config file for ssh, assuming ssh is off.
dbt - 2022-05-23 08:28:24 INFO () LineGobbler(voidCall):82 - Running: dbt run --profiles-dir=/data/11619/0/transform --project-dir=/data/11619/0/transform/git_repo
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - Running with dbt=0.19.1
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - There are 1 unused configuration paths:
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - - models.kobold_production.staging
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - 
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - Found 1 model, 2 tests, 0 snapshots, 0 analyses, 138 macros, 0 operations, 0 seed files, 0 sources, 0 exposures
dbt - 2022-05-23 08:28:26 INFO () LineGobbler(voidCall):82 - 
dbt - 2022-05-23 08:28:27 INFO () LineGobbler(voidCall):82 - 08:28:26 | Concurrency: 32 threads (target='prod')
dbt - 2022-05-23 08:28:27 INFO () LineGobbler(voidCall):82 - 08:28:26 | 
dbt - 2022-05-23 08:28:27 INFO () LineGobbler(voidCall):82 - 08:28:27 | 1 of 1 START table model public.transactions................................................................. [RUN]
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - 08:28:35 | 1 of 1 OK created table model public.transactions............................................................ [SELECT 368144 in 8.42s]
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - 08:28:35 | 
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - 08:28:35 | Finished running 1 table model in 8.53s.
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - 
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - Completed successfully
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - 
dbt - 2022-05-23 08:28:35 INFO () LineGobbler(voidCall):82 - Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2022-05-23 08:28:35 INFO () DbtTransformationWorker(run):64 - Dbt Transformation executed in 0.
2022-05-23 08:28:35 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2022-05-23 08:28:35 WARN () JobNotifier(notifyJob):104 - Failed to successfully notify success: io.airbyte.config.Notification@494110b9[notificationType=slack,sendOnSuccess=false,sendOnFailure=false,slackConfiguration=io.airbyte.config.SlackNotificationConfiguration@7b801bbb[webhook=https://hooks.slack.com/services/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],additionalProperties={}]