2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: must be a constant value STANDARD, $.method: does not have a value in the enumeration [STANDARD]
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.private_key: is missing but it is required
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.password: object found, string expected
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Standard]
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Internal Staging]
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.access_key_id: object found, string expected, $.secret_access_key: object found, string expected
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [GCS Staging], $.project_id: is missing but it is required, $.bucket_name: is missing but it is required, $.credentials_json: is missing but it is required
2022-10-12 06:09:39 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Azure Blob Staging], $.azure_blob_storage_account_name: is missing but it is required, $.azure_blob_storage_container_name: is missing but it is required, $.azure_blob_storage_sas_token: is missing but it is required
2022-10-12 06:09:39 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/48424/0/logs.log
2022-10-12 06:09:39 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.14
2022-10-12 06:09:39 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:39 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-10-12 06:09:39 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:39 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mysql:1.0.3 exists...
2022-10-12 06:09:39 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mysql:1.0.3 was found locally.
2022-10-12 06:09:39 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-mysql-check-48424-0-vdbje with resources io.airbyte.config.ResourceRequirements@7cab44ae[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-10-12 06:09:39 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/48424/0 --log-driver none --name source-mysql-check-48424-0-vdbje --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:1.0.3 -e AIRBYTE_VERSION=0.40.14 -e WORKER_JOB_ID=48424 airbyte/source-mysql:1.0.3 check --config source_config.json
2022-10-12 06:09:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-10-12 06:09:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - integration args: {check=null, config=source_config.json}
2022-10-12 06:09:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-10-12 06:09:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Command: CHECK
2022-10-12 06:09:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-10-12 06:09:47 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:09:47 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Starting connection with method: NO_TUNNEL
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Starting...
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Start completed.
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Attempting to get metadata from the database to see if we can connect.
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown initiated...
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown completed.
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-10-12 06:09:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - completed source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-10-12 06:09:50 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:50 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/48424/0/logs.log
2022-10-12 06:09:50 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.14
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.38 exists...
2022-10-12 06:09:50 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.38 was found locally.
2022-10-12 06:09:50 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-check-48424-0-hwwwk with resources io.airbyte.config.ResourceRequirements@7cab44ae[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-10-12 06:09:50 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/48424/0 --log-driver none --name destination-snowflake-check-48424-0-hwwwk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.38 -e AIRBYTE_VERSION=0.40.14 -e WORKER_JOB_ID=48424 airbyte/destination-snowflake:0.4.38 check --config source_config.json
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - integration args: {check=null, config=source_config.json}
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Command: CHECK
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-10-12 06:09:55 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:09:55 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Using destination type: COPY_S3
2022-10-12 06:09:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Creating S3 client...
2022-10-12 06:09:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Starting...
2022-10-12 06:09:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@4dcbae55
2022-10-12 06:09:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Start completed.
2022-10-12 06:09:59 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - closing connection
2022-10-12 06:10:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Storage Object my-bucket/_ANALYTICS__AIRBYTE_CONNECTION_TEST_BD1DB760_0B66_4E70_9DBD_1884CAF5B143 does not exist in bucket; creating...
2022-10-12 06:10:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Storage Object my-bucket/_ANALYTICS__AIRBYTE_CONNECTION_TEST_BD1DB760_0B66_4E70_9DBD_1884CAF5B143 has been created in bucket.
2022-10-12 06:10:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Deleting objects _ANALYTICS__AIRBYTE_CONNECTION_TEST_BD1DB760_0B66_4E70_9DBD_1884CAF5B143/
2022-10-12 06:10:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Storage bucket _ANALYTICS__AIRBYTE_CONNECTION_TEST_BD1DB760_0B66_4E70_9DBD_1884CAF5B143 has been cleaned-up (1 objects were deleted)...
2022-10-12 06:10:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown initiated...
2022-10-12 06:10:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown completed.
2022-10-12 06:10:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-10-12 06:10:08 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:10:08 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/48424/0/logs.log
2022-10-12 06:10:08 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.14
2022-10-12 06:10:08 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-10-12 06:10:08 INFO i.a.c.EnvConfigs(getEnvOrDefault):1091 - Using default value for environment variable METRIC_CLIENT: ''
2022-10-12 06:10:08 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to
2022-10-12 06:10:08 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-10-12 06:10:08 INFO i.a.w.g.DefaultReplicationWorker(run):122 - start sync worker. job id: 48424 attempt id: 0
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:10:08 INFO i.a.w.g.DefaultReplicationWorker(run):135 - configured sync modes: {myschema.mytable=incremental - append_dedup}
2022-10-12 06:10:08 INFO i.a.w.i.DefaultAirbyteDestination(start):65 - Running destination...
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.38 exists...
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.38 was found locally.
2022-10-12 06:10:08 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-write-48424-0-lenzg with resources io.airbyte.config.ResourceRequirements@799f8f28[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-10-12 06:10:08 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/48424/0 --log-driver none --name destination-snowflake-write-48424-0-lenzg --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.38 -e AIRBYTE_VERSION=0.40.14 -e WORKER_JOB_ID=48424 airbyte/destination-snowflake:0.4.38 write --config destination_config.json --catalog destination_catalog.json
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mysql:1.0.3 exists...
2022-10-12 06:10:08 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mysql:1.0.3 was found locally.
2022-10-12 06:10:08 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-mysql-read-48424-0-jqfku with resources io.airbyte.config.ResourceRequirements@1de0eb93[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-10-12 06:10:08 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/48424/0 --log-driver none --name source-mysql-read-48424-0-jqfku --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:1.0.3 -e AIRBYTE_VERSION=0.40.14 -e WORKER_JOB_ID=48424 airbyte/source-mysql:1.0.3 read --config source_config.json --catalog source_catalog.json
2022-10-12 06:10:08 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Waiting for source and destination threads to complete.
2022-10-12 06:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):435 - Destination output thread started.
2022-10-12 06:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):322 - Replication thread started.
2022-10-12 06:10:15 source > starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-10-12 06:10:16 destination > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-10-12 06:10:16 destination > Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-10-12 06:10:16 destination > Command: WRITE
2022-10-12 06:10:16 destination > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-10-12 06:10:20 source > integration args: {read=null, catalog=source_catalog.json, config=source_config.json}
2022-10-12 06:10:20 source > Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-10-12 06:10:20 source > Command: READ
2022-10-12 06:10:20 source > Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'}
2022-10-12 06:10:20 destination > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:10:20 destination > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:10:20 destination > Using destination type: COPY_S3
2022-10-12 06:10:21 source > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:10:21 source > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:10:21 source > Starting connection with method: NO_TUNNEL
2022-10-12 06:10:21 source > Global state manager selected to manage state object with type GLOBAL.
2022-10-12 06:10:21 source > No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='mytable', namespace='myschema'}, New Cursor Field: null. Resetting cursor value
2022-10-12 06:10:21 source > Initialized CDC state with: io.airbyte.integrations.source.relationaldb.models.CdcState@5dda14d0[state=<null>,additionalProperties={}]
2022-10-12 06:10:21 destination > Creating S3 client...
2022-10-12 06:10:21 source > HikariPool-1 - Starting...
2022-10-12 06:10:21 source > HikariPool-1 - Start completed.
2022-10-12 06:10:22 source > Internal schemas to exclude: [performance_schema, information_schema, mysql, sys]
2022-10-12 06:10:22 destination > Write config: WriteConfig{streamName=test_mytable, namespace=my_schema, outputSchemaName=my_schema, tmpTableName=_airbyte_tmp_nyf_test_mytable, outputTableName=_airbyte_raw_test_mytable, syncMode=append_dedup}
2022-10-12 06:10:22 destination > class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-10-12 06:10:22 destination > Preparing tmp tables in destination started for 1 streams
2022-10-12 06:10:22 destination > Preparing staging area in destination started for schema my_schema stream test_mytable: tmp table: _airbyte_tmp_nyf_test_mytable, stage: my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/
...
2022-10-12 06:10:24 WARN c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword airbyte_type - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-10-12 06:10:24 destination > Storage Object my-bucket/my_schema_TEST_mytable does not exist in bucket; creating...
2022-10-12 06:10:25 destination > Storage Object my-bucket/my_schema_TEST_mytable has been created in bucket.
2022-10-12 06:10:25 destination > Preparing staging area in destination completed for schema my_schema stream test_mytable
2022-10-12 06:10:25 destination > Preparing tmp tables in destination completed.
2022-10-12 06:10:25 destination > Starting a new buffer for stream test_mytable (current state: 0 bytes in 0 buffe2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 1000 (442 2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 2000 (886 2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 3000 (1 MB)
2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 4000 (1 MB)
2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 5000 (2 2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 6000 (2 MB)
2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 7000 (3 MB)
2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 8000 (3 MB)
2022-10-12 06:10:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 9000 (3 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 10000 (4 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 11000 (4 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 12000 (5 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 13000 (5 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 14000 (6 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 15000 (6 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 16000 (6 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 17000 (7 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 18000 (7 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 19000 (8 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 20000 (8 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 21000 (9 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 22000 (9 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 23000 (10 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 24000 (10 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 25000 (10 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 26000 (11 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 27000 (11 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 28000 (12 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 29000 (12 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 30000 (13 MB)
2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 31000 (13 2022-10-12 06:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 32000 (13 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 33000 (14 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 34000 (14 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 35000 (15 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 36000 (15 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 37000 (16 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 38000 (16 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 39000 (17 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 40000 (17 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 41000 (17 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 42000 (18 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 43000 (18 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 44000 (19 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 45000 (19 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 46000 (20 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 47000 (20 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 48000 (21 MB)
2022-10-12 06:10:27 source > 59392 records sent during previous 00:00:05.078, last recorded offset: {ts_sec=1665555024, file=mysql-bin-changelog.260402, pos=161242, snapshot=true}
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 49000 (21 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 50000 (21 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 51000 (22 MB)
2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 52000 (22 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 53000 (23 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 54000 (23 2022-10-12 06:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 55000 (24 2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 56000 (24 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 57000 (25 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 58000 (25 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 59000 (25 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 60000 (26 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 61000 (26 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 62000 (27 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 63000 (27 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 64000 (28 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 65000 (28 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 66000 (29 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 67000 (29 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 68000 (29 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 69000 (30 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 70000 (30 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 71000 (31 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 72000 (31 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 73000 (32 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 74000 (32 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 75000 (32 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 76000 (33 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 77000 (33 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 78000 (34 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 79000 (34 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 80000 (35 MB)
2022-10-12 06:10:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 81000 (35 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 82000 (36 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 83000 (36 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 84000 (36 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 85000 (37 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 86000 (37 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 87000 (38 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 88000 (38 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 89000 (39 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 90000 (39 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 91000 (40 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 92000 (40 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 93000 (40 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 94000 (41 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 95000 (41 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 96000 (42 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 97000 (42 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 98000 (43 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 99000 (43 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 100000 (44 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 101000 (44 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 102000 (44 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 103000 (45 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 104000 (45 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 105000 (46 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 106000 (46 MB)
2022-10-12 06:10:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 107000 (47 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 108000 (47 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 109000 (48 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 110000 (48 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 111000 (48 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 112000 (49 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 113000 (49 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 114000 (50 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 115000 (50 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 116000 (51 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 117000 (51 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 118000 (52 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 119000 (52 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 120000 (52 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 121000 (53 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 122000 (53 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 123000 (54 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 124000 (54 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 125000 (55 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 126000 (55 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 127000 (56 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 128000 (56 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 129000 (56 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 130000 (57 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 131000 (57 MB)
2022-10-12 06:10:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 132000 (58 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 133000 (58 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 134000 (59 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 135000 (59 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 136000 (60 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 137000 (60 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 138000 (60 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 139000 (61 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 140000 (61 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 141000 (62 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 142000 (62 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 143000 (63 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 144000 (63 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 145000 (64 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 146000 (64 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 147000 (64 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 148000 (65 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 149000 (65 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 150000 (66 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 151000 (66 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 152000 (67 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 153000 (67 MB)
2022-10-12 06:10:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 154000 (68 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 155000 (68 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 156000 (68 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 157000 (69 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 158000 (69 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 159000 (70 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 160000 (70 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 161000 (71 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 162000 (71 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 163000 (72 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 164000 (72 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 165000 (72 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 166000 (73 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 167000 (73 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 168000 (74 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 169000 (74 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 170000 (75 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 171000 (75 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 172000 (76 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 173000 (76 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 174000 (76 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 175000 (77 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 176000 (77 MB)
2022-10-12 06:10:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 177000 (78 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 178000 (78 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 179000 (79 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 180000 (79 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 181000 (80 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 182000 (80 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 183000 (80 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 184000 (81 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 185000 (81 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 186000 (82 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 187000 (82 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 188000 (83 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 189000 (83 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 190000 (84 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 191000 (84 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 192000 (84 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 193000 (85 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 194000 (85 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 195000 (86 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 196000 (86 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 197000 (87 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 198000 (87 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 199000 (88 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 200000 (88 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 201000 (88 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 202000 (89 MB)
2022-10-12 06:10:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 203000 (89 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 204000 (90 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 205000 (90 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 206000 (91 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 207000 (91 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 208000 (92 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 209000 (92 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 210000 (92 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 211000 (93 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 212000 (93 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 213000 (94 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 214000 (94 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 215000 (95 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 216000 (95 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 217000 (96 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 218000 (96 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 219000 (96 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 220000 (97 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 221000 (97 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 222000 (98 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 223000 (98 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 224000 (99 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 225000 (99 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 226000 (100 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 227000 (100 MB)
2022-10-12 06:10:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 228000 (100 MB)
2022-10-12 06:10:35 source > 	 Exported 237572 of 841853 records for table 'myschema.mytable' after 00:00:10.415
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 229000 (101 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 230000 (101 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 231000 (102 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 232000 (102 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 233000 (103 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 234000 (103 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 235000 (104 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 236000 (104 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 237000 (104 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 238000 (105 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 239000 (105 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 240000 (106 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 241000 (106 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 242000 (107 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 243000 (107 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 244000 (108 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 245000 (108 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 246000 (108 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 247000 (109 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 248000 (109 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 249000 (110 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 250000 (110 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 251000 (111 MB)
2022-10-12 06:10:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 252000 (111 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 253000 (112 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 254000 (112 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 255000 (112 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 256000 (113 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 257000 (113 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 258000 (114 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 259000 (114 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 260000 (115 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 261000 (115 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 262000 (116 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 263000 (116 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 264000 (116 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 265000 (117 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 266000 (117 MB)
2022-10-12 06:10:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 267000 (118 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 268000 (118 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 269000 (119 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 270000 (119 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 271000 (120 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 272000 (120 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 273000 (120 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 274000 (121 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 275000 (121 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 276000 (122 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 277000 (122 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 278000 (123 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 279000 (123 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 280000 (124 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 281000 (124 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 282000 (124 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 283000 (125 MB)
2022-10-12 06:10:37 source > 235520 records sent during previous 00:00:09.955, last recorded offset: {ts_sec=1665555024, file=mysql-bin-changelog.260402, pos=161242, snapshot=true}
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 284000 (125 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 285000 (126 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 286000 (126 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 287000 (127 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 288000 (127 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 289000 (128 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 290000 (128 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 291000 (128 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 292000 (129 MB)
2022-10-12 06:10:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 293000 (129 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 294000 (130 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 295000 (130 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 296000 (131 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 297000 (131 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 298000 (132 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 299000 (132 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 300000 (132 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 301000 (133 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 302000 (133 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 303000 (134 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 304000 (134 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 305000 (135 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 306000 (135 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 307000 (136 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 308000 (136 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 309000 (137 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 310000 (137 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 311000 (137 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 312000 (138 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 313000 (138 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 314000 (139 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 315000 (139 MB)
2022-10-12 06:10:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 316000 (140 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 317000 (140 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 318000 (141 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 319000 (141 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 320000 (141 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 321000 (142 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 322000 (142 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 323000 (143 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 324000 (143 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 325000 (144 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 326000 (144 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 327000 (145 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 328000 (145 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 329000 (145 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 330000 (146 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 331000 (146 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 332000 (147 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 333000 (147 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 334000 (148 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 335000 (148 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 336000 (149 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 337000 (149 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 338000 (149 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 339000 (150 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 340000 (150 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 341000 (151 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 342000 (151 MB)
2022-10-12 06:10:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 343000 (152 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 344000 (152 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 345000 (153 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 346000 (153 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 347000 (153 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 348000 (154 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 349000 (154 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 350000 (155 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 351000 (155 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 352000 (156 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 353000 (156 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 354000 (157 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 355000 (157 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 356000 (157 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 357000 (158 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 358000 (158 MB)
2022-10-12 06:10:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 359000 (159 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 360000 (159 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 361000 (160 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 362000 (160 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 363000 (161 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 364000 (161 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 365000 (161 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 366000 (162 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 367000 (162 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 368000 (163 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 369000 (163 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 370000 (164 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 371000 (164 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 372000 (165 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 373000 (165 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 374000 (165 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 375000 (166 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 376000 (166 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 377000 (167 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 378000 (167 MB)
2022-10-12 06:10:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 379000 (168 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 380000 (168 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 381000 (169 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 382000 (169 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 383000 (169 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 384000 (170 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 385000 (170 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 386000 (171 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 387000 (171 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 388000 (172 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 389000 (172 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 390000 (173 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 391000 (173 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 392000 (173 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 393000 (174 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 394000 (174 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 395000 (175 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 396000 (175 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 397000 (176 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 398000 (176 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 399000 (177 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 400000 (177 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 401000 (177 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 402000 (178 MB)
2022-10-12 06:10:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 403000 (178 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 404000 (179 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 405000 (179 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 406000 (180 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 407000 (180 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 408000 (181 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 409000 (181 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 410000 (181 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 411000 (182 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 412000 (182 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 413000 (183 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 414000 (183 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 415000 (184 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 416000 (184 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 417000 (185 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 418000 (185 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 419000 (185 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 420000 (186 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 421000 (186 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 422000 (187 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 423000 (187 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 424000 (188 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 425000 (188 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 426000 (189 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 427000 (189 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 428000 (189 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 429000 (190 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 430000 (190 MB)
2022-10-12 06:10:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 431000 (191 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 432000 (191 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 433000 (192 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 434000 (192 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 435000 (193 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 436000 (193 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 437000 (193 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 438000 (194 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 439000 (194 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 440000 (195 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 441000 (195 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 442000 (196 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 443000 (196 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 444000 (197 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 445000 (197 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 446000 (197 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 447000 (198 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 448000 (198 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 449000 (199 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 450000 (199 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 451000 (200 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 452000 (200 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 453000 (201 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 454000 (201 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 455000 (201 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 456000 (202 MB)
2022-10-12 06:10:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 457000 (202 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 458000 (203 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 459000 (203 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 460000 (204 MB)
2022-10-12 06:10:45 source > 	 Exported 471044 of 841853 records for table 'myschema.mytable' after 00:00:20.504
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 461000 (204 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 462000 (205 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 463000 (205 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 464000 (205 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 465000 (206 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 466000 (206 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 467000 (207 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 468000 (207 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 469000 (208 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 470000 (208 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 471000 (209 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 472000 (209 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 473000 (209 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 474000 (210 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 475000 (210 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 476000 (211 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 477000 (211 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 478000 (212 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 479000 (212 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 480000 (213 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 481000 (213 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 482000 (214 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 483000 (214 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 484000 (214 MB)
2022-10-12 06:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 485000 (215 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 486000 (215 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 487000 (216 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 488000 (216 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 489000 (217 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 490000 (217 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 491000 (218 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 492000 (218 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 493000 (218 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 494000 (219 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 495000 (219 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 496000 (220 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 497000 (220 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 498000 (221 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 499000 (221 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 500000 (222 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 501000 (222 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 502000 (222 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 503000 (223 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 504000 (223 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 505000 (224 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 506000 (224 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 507000 (225 MB)
2022-10-12 06:10:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 508000 (225 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 509000 (226 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 510000 (226 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 511000 (226 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 512000 (227 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 513000 (227 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 514000 (228 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 515000 (228 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 516000 (229 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 517000 (229 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 518000 (230 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 519000 (230 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 520000 (230 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 521000 (231 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 522000 (231 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 523000 (232 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 524000 (232 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 525000 (233 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 526000 (233 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 527000 (234 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 528000 (234 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 529000 (234 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 530000 (235 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 531000 (235 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 532000 (236 MB)
2022-10-12 06:10:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 533000 (236 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 534000 (237 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 535000 (237 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 536000 (238 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 537000 (238 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 538000 (238 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 539000 (239 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 540000 (239 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 541000 (240 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 542000 (240 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 543000 (241 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 544000 (241 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 545000 (242 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 546000 (242 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 547000 (242 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 548000 (243 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 549000 (243 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 550000 (244 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 551000 (244 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 552000 (245 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 553000 (245 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 554000 (246 MB)
2022-10-12 06:10:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 555000 (246 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 556000 (246 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 557000 (247 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 558000 (247 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 559000 (248 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 560000 (248 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 561000 (249 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 562000 (249 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 563000 (250 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 564000 (250 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 565000 (250 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 566000 (251 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 567000 (251 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 568000 (252 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 569000 (252 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 570000 (253 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 571000 (253 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 572000 (254 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 573000 (254 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 574000 (254 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 575000 (255 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 576000 (255 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 577000 (256 MB)
2022-10-12 06:10:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 578000 (256 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 579000 (257 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 580000 (257 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 581000 (258 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 582000 (258 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 583000 (258 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 584000 (259 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 585000 (259 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 586000 (260 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 587000 (260 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 588000 (261 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 589000 (261 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 590000 (262 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 591000 (262 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 592000 (263 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 593000 (263 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 594000 (263 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 595000 (264 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 596000 (264 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 597000 (265 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 598000 (265 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 599000 (266 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 600000 (266 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 601000 (267 MB)
2022-10-12 06:10:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 602000 (267 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 603000 (267 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 604000 (268 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 605000 (268 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 606000 (269 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 607000 (269 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 608000 (270 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 609000 (270 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 610000 (271 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 611000 (271 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 612000 (271 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 613000 (272 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 614000 (272 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 615000 (273 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 616000 (273 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 617000 (274 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 618000 (274 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 619000 (275 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 620000 (275 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 621000 (275 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 622000 (276 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 623000 (276 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 624000 (277 MB)
2022-10-12 06:10:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 625000 (277 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 626000 (278 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 627000 (278 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 628000 (279 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 629000 (279 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 630000 (279 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 631000 (280 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 632000 (280 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 633000 (281 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 634000 (281 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 635000 (282 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 636000 (282 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 637000 (283 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 638000 (283 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 639000 (283 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 640000 (284 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 641000 (284 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 642000 (285 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 643000 (285 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 644000 (286 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 645000 (286 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 646000 (287 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 647000 (287 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 648000 (287 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 649000 (288 MB)
2022-10-12 06:10:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 650000 (288 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 651000 (289 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 652000 (289 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 653000 (290 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 654000 (290 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 655000 (291 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 656000 (291 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 657000 (292 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 658000 (292 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 659000 (292 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 660000 (293 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 661000 (293 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 662000 (294 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 663000 (294 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 664000 (295 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 665000 (295 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 666000 (296 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 667000 (296 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 668000 (296 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 669000 (297 MB)
2022-10-12 06:10:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 670000 (297 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 671000 (298 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 672000 (298 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 673000 (299 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 674000 (299 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 675000 (300 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 676000 (300 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 677000 (300 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 678000 (301 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 679000 (301 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 680000 (302 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 681000 (302 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 682000 (303 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 683000 (303 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 684000 (304 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 685000 (304 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 686000 (304 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 687000 (305 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 688000 (305 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 689000 (306 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 690000 (306 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 691000 (307 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 692000 (307 MB)
2022-10-12 06:10:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 693000 (308 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 694000 (308 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 695000 (308 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 696000 (309 MB)
2022-10-12 06:10:55 source > 	 Exported 714756 of 841853 records for table 'myschema.mytable' after 00:00:30.551
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 697000 (309 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 698000 (310 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 699000 (310 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 700000 (311 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 701000 (311 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 702000 (312 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 703000 (312 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 704000 (312 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 705000 (313 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 706000 (313 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 707000 (314 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 708000 (314 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 709000 (315 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 710000 (315 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 711000 (315 MB)
2022-10-12 06:10:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 712000 (316 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 713000 (316 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 714000 (317 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 715000 (317 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 716000 (318 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 717000 (318 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 718000 (319 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 719000 (319 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 720000 (319 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 721000 (320 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 722000 (320 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 723000 (321 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 724000 (321 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 725000 (322 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 726000 (322 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 727000 (323 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 728000 (323 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 729000 (323 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 730000 (324 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 731000 (324 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 732000 (325 MB)
2022-10-12 06:10:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 733000 (325 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 734000 (326 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 735000 (326 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 736000 (327 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 737000 (327 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 738000 (327 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 739000 (328 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 740000 (328 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 741000 (329 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 742000 (329 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 743000 (330 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 744000 (330 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 745000 (331 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 746000 (331 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 747000 (331 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 748000 (332 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 749000 (332 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 750000 (333 MB)
2022-10-12 06:10:57 source > 466944 records sent during previous 00:00:20.089, last recorded offset: {ts_sec=1665555024, file=mysql-bin-changelog.260402, pos=161242, snapshot=true}
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 751000 (333 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 752000 (334 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 753000 (334 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 754000 (335 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 755000 (335 MB)
2022-10-12 06:10:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 756000 (335 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 757000 (336 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 758000 (336 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 759000 (337 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 760000 (337 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 761000 (338 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 762000 (338 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 763000 (339 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 764000 (339 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 765000 (339 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 766000 (340 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 767000 (340 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 768000 (341 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 769000 (341 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 770000 (342 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 771000 (342 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 772000 (342 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 773000 (343 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 774000 (343 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 775000 (344 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 776000 (344 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 777000 (345 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 778000 (345 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 779000 (346 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 780000 (346 MB)
2022-10-12 06:10:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 781000 (346 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 782000 (347 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 783000 (347 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 784000 (348 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 785000 (348 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 786000 (349 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 787000 (349 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 788000 (350 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 789000 (350 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 790000 (350 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 791000 (351 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 792000 (351 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 793000 (352 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 794000 (352 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 795000 (353 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 796000 (353 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 797000 (354 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 798000 (354 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 799000 (354 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 800000 (355 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 801000 (355 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 802000 (356 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 803000 (356 MB)
2022-10-12 06:10:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 804000 (357 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 805000 (357 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 806000 (358 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 807000 (358 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 808000 (358 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 809000 (359 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 810000 (359 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 811000 (360 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 812000 (360 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 813000 (361 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 814000 (361 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 815000 (362 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 816000 (362 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 817000 (362 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 818000 (363 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 819000 (363 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 820000 (364 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 821000 (364 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 822000 (365 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 823000 (365 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 824000 (366 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 825000 (366 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 826000 (366 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 827000 (367 MB)
2022-10-12 06:11:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 828000 (367 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 829000 (368 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 830000 (368 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 831000 (369 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 832000 (369 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 833000 (370 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 834000 (370 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 835000 (370 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 836000 (371 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 837000 (371 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 838000 (372 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 839000 (372 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 840000 (373 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 841000 (373 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 842000 (374 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 843000 (374 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 844000 (374 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 845000 (375 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 846000 (375 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 847000 (376 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 848000 (376 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 849000 (377 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 850000 (377 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 851000 (378 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 852000 (378 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 853000 (378 MB)
2022-10-12 06:11:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 854000 (379 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 855000 (379 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 856000 (380 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 857000 (380 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 858000 (381 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 859000 (381 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 860000 (382 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 861000 (382 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 862000 (382 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 863000 (383 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 864000 (383 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 865000 (384 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 866000 (384 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 867000 (385 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 868000 (385 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 869000 (385 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 870000 (386 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 871000 (386 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 872000 (387 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 873000 (387 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 874000 (388 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 875000 (388 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 876000 (389 MB)
2022-10-12 06:11:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 877000 (389 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 878000 (389 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 879000 (390 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 880000 (390 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 881000 (391 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 882000 (391 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 883000 (392 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 884000 (392 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 885000 (393 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 886000 (393 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 887000 (393 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 888000 (394 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 889000 (394 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 890000 (395 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 891000 (395 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 892000 (396 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 893000 (396 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 894000 (397 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 895000 (397 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 896000 (397 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 897000 (398 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 898000 (398 MB)
2022-10-12 06:11:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 899000 (399 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 900000 (399 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 901000 (400 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 902000 (400 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 903000 (401 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 904000 (401 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 905000 (401 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 906000 (402 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 907000 (402 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 908000 (403 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 909000 (403 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 910000 (404 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 911000 (404 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 912000 (405 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 913000 (405 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 914000 (405 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 915000 (406 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 916000 (406 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 917000 (407 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 918000 (407 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 919000 (408 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 920000 (408 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 921000 (409 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 922000 (409 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 923000 (409 MB)
2022-10-12 06:11:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 924000 (410 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 925000 (410 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 926000 (411 MB)
2022-10-12 06:11:05 source > 	 Finished exporting 944198 records for table 'myschema.mytable'; total duration '00:00:40.47'
2022-10-12 06:11:05 source > Snapshot - Final stage
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 927000 (411 MB)
2022-10-12 06:11:05 source > Starting streaming
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 928000 (412 MB)
2022-10-12 06:11:05 source > Oct 12, 2022 6:11:05 AM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2022-10-12 06:11:05 source > INFO: Connected to my-host.rds.amazonaws.com:3306 at mysql-bin-changelog.260402/161242 (sid:5827, cid:167437)
2022-10-12 06:11:05 source > GTID set purged on server:
2022-10-12 06:11:05 source > Skip 0 events on streaming start
2022-10-12 06:11:05 source > Skip 0 rows on streaming start
2022-10-12 06:11:05 source > Creating thread debezium-mysqlconnector-binlog-client
2022-10-12 06:11:05 source > Creating thread debezium-mysqlconnector-binlog-client
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 929000 (412 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 930000 (413 MB)
2022-10-12 06:11:05 source > Waiting for keepalive thread to start
2022-10-12 06:11:05 source > Creating thread debezium-mysqlconnector-binlog-client
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 931000 (413 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 932000 (413 MB)
2022-10-12 06:11:05 source > Keepalive thread is running
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 933000 (414 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 934000 (414 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 935000 (415 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 936000 (415 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 937000 (416 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 938000 (416 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 939000 (417 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 940000 (417 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 941000 (417 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 942000 (418 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 943000 (418 MB)
2022-10-12 06:11:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 944000 (419 MB)
2022-10-12 06:12:05 source > Closing cause next is returned as null
2022-10-12 06:12:05 source > Stopping the embedded engine
2022-10-12 06:12:05 source > Waiting for PT5M for connector to stop
2022-10-12 06:12:06 source > Stopping the task and engine
2022-10-12 06:12:06 source > Stopping down connector
2022-10-12 06:12:06 source > Oct 12, 2022 6:12:06 AM com.github.shyiko.mysql.binlog.BinaryLogClient$5 run
2022-10-12 06:12:06 source > INFO: threadExecutor is shut down, terminating keepalive thread
2022-10-12 06:12:06 source > Finished streaming
2022-10-12 06:12:06 source > Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, ts_sec=1665555024, file=mysql-bin-changelog.260403, pos=406370, server_id=1804247894, event=1}
2022-10-12 06:12:06 source > Connection gracefully closed
2022-10-12 06:12:06 source > Stopped FileOffsetBackingStore
2022-10-12 06:12:06 source > Debezium engine shutdown.
2022-10-12 06:12:06 source > no record found. polling again.
2022-10-12 06:12:06 source > Closing database connection pool.
2022-10-12 06:12:06 source > HikariPool-1 - Shutdown initiated...
2022-10-12 06:12:06 source > HikariPool-1 - Shutdown completed.
2022-10-12 06:12:06 source > Closed database connection pool.
2022-10-12 06:12:06 source > Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-10-12 06:12:06 source > completed source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-10-12 06:12:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):355 - Source has no more messages, closing connection.
2022-10-12 06:12:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):363 - Total records read: 944199 (419 MB)
2022-10-12 06:12:08 INFO i.a.w.g.DefaultReplicationWorker(run):182 - One of source or destination thread complete. Waiting on the other.
2022-10-12 06:12:08 destination > Airbyte message consumer: succeeded.
2022-10-12 06:12:08 destination > executing on success close procedure.
2022-10-12 06:12:08 destination > Flushing all 1 current buffers (53 MB in total)
2022-10-12 06:12:08 destination > Flushing buffer of stream test_mytable (53 MB)
2022-10-12 06:12:08 destination > Flushing buffer for stream test_mytable (53 MB) to staging
2022-10-12 06:12:08 destination > Wrapping up compression and write GZIP trailer data.
2022-10-12 06:12:08 destination > Finished writing data to b08fcef8-4fd9-4a54-bebc-f1262e87bdac6523504835853239400.csv.gz (53 MB)
2022-10-12 06:12:08 destination > Initiated multipart upload to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with full ID NUsdUGa9WzUKxaiemULL74csFvIMZJCbzm_sq9BEVahCDBWSGhQfD5jdRJtkdDXpSzfXic2bQB9O1x7EPATMfX4TnVSmTdKbSCY9_odRZGYOytJ45j3E7D5u_WOBNnGA
2022-10-12 06:12:08 destination > Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-10-12 06:12:08 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Finished uploading [Part number 2 containing 10.01 MB]
2022-10-12 06:12:08 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Finished uploading [Part number 4 containing 10.01 MB]
2022-10-12 06:12:08 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Finished uploading [Part number 1 containing 10.01 MB]
2022-10-12 06:12:08 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Finished uploading [Part number 3 containing 10.01 MB]
2022-10-12 06:12:09 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Finished uploading [Part number 5 containing 13.51 MB]
2022-10-12 06:12:09 destination > [Manager uploading to my-bucket/my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz with id NUsdUGa9W...u_WOBNnGA]: Completed
2022-10-12 06:12:09 destination > Uploaded buffer file to storage: b08fcef8-4fd9-4a54-bebc-f1262e87bdac6523504835853239400.csv.gz -> my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/0.csv.gz (filename: 0.csv.gz)
2022-10-12 06:12:09 destination > Deleting tempFile data b08fcef8-4fd9-4a54-bebc-f1262e87bdac6523504835853239400.csv.gz
2022-10-12 06:12:09 destination > Closing buffer for stream test_mytable
2022-10-12 06:12:09 destination > Copying into tables in destination started for 1 streams
2022-10-12 06:12:09 destination > Copying stream test_mytable of schema my_schema into tmp table _airbyte_tmp_nyf_test_mytable to final table _airbyte_raw_test_mytable from stage path my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/ with 1 file(s) [0.csv.gz]
2022-10-12 06:12:09 destination > Starting copy to tmp table from stage: _airbyte_tmp_nyf_test_mytable in destination from stage: my_schema_TEST_mytable/2022/10/12/06/59A316B0-E9D4-4093-87BF-A4E47D6E41BF/, schema: my_schema, .
2022-10-12 06:12:35 destination > Copy to tmp table test_app_myschema._airbyte_tmp_nyf_test_mytable in destination complete.
2022-10-12 06:12:35 destination > No onDestinationCloseOperations required for this destination.
2022-10-12 06:12:35 destination > Executing finalization of tables.
2022-10-12 06:12:45 destination > Finalizing tables in destination completed.
2022-10-12 06:12:45 destination > Cleaning up destination started for 1 streams
2022-10-12 06:12:45 destination > Cleaning tmp table in destination started for stream test_mytable. schema my_schema, tmp table name: _airbyte_tmp_nyf_test_mytable
2022-10-12 06:12:45 destination > Cleaning up destination completed.
2022-10-12 06:12:45 destination > Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-10-12 06:12:48 INFO i.a.w.g.DefaultReplicationWorker(run):184 - Source and destination threads complete.
2022-10-12 06:12:48 INFO i.a.w.g.DefaultReplicationWorker(run):279 - Source output at least one state message
2022-10-12 06:12:48 INFO i.a.w.g.DefaultReplicationWorker(run):300 - sync summary: {
  "status" : "completed",
  "recordsSynced" : 944198,
  "bytesSynced" : 439710520,
  "startTime" : 1665555008784,
  "endTime" : 1665555168662,
  "totalStats" : {
    "recordsEmitted" : 944198,
    "bytesEmitted" : 439710520,
    "sourceStateMessagesEmitted" : 1,
    "destinationStateMessagesEmitted" : 1,
    "recordsCommitted" : 944198,
    "meanSecondsBeforeSourceStateMessageEmitted" : 101,
    "maxSecondsBeforeSourceStateMessageEmitted" : 101,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 39,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 39
  },
  "streamStats" : [ {
    "streamName" : "test_mytable",
    "stats" : {
      "recordsEmitted" : 944198,
      "bytesEmitted" : 439710520,
      "recordsCommitted" : 944198
    }
  } ]
}
2022-10-12 06:12:48 INFO i.a.w.g.DefaultReplicationWorker(run):301 - failures: [ ]
2022-10-12 06:12:48 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-10-12 06:12:48 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:12:48 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2022-10-12 06:12:48 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:12:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):162 - Sync summary length: 136703
2022-10-12 06:12:48 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):280 - Stopping temporal heartbeating...
2022-10-12 06:12:48 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2022-10-12 06:12:49 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/48424/0/logs.log
2022-10-12 06:12:49 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.14
2022-10-12 06:12:49 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:12:49 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION -----
2022-10-12 06:12:49 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:12:49 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):134 - Running with normalization version: airbyte/normalization-snowflake:0.2.22
2022-10-12 06:12:49 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-snowflake:0.2.22 exists...
2022-10-12 06:12:49 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-snowflake:0.2.22 was found locally.
2022-10-12 06:12:49 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = normalization-snowflake-normalize-48424-0-smfoe with resources io.airbyte.config.ResourceRequirements@4c61df40[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-10-12 06:12:49 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/48424/0/normalize --log-driver none --name normalization-snowflake-normalize-48424-0-smfoe --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.40.14 airbyte/normalization-snowflake:0.2.22 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-10-12 06:12:52 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/48424/0/normalize
2022-10-12 06:12:53 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.SNOWFLAKE: 'snowflake'>, out='/data/48424/0/normalize')
2022-10-12 06:12:53 normalization > transform_snowflake
2022-10-12 06:12:53 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/48424/0/normalize --catalog destination_catalog.json --out /data/48424/0/normalize/models/generated/ --json-column _airbyte_data
2022-10-12 06:12:54 normalization > Processing destination_catalog.json...
2022-10-12 06:12:54 normalization >   Generating airbyte_ctes/my_schema/TEST_mytable_AB1.sql from test_mytable
2022-10-12 06:12:54 normalization >   Generating airbyte_ctes/my_schema/TEST_mytable_AB2.sql from test_mytable
2022-10-12 06:12:54 normalization >   Generating airbyte_views/my_schema/TEST_mytable_STG.sql from test_mytable
2022-10-12 06:12:54 normalization >   Generating airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql from test_mytable
2022-10-12 06:12:54 normalization >   Generating airbyte_incremental/my_schema/TEST_mytable.sql from test_mytable
2022-10-12 06:12:54 normalization > detected no config file for ssh, assuming ssh is off.
2022-10-12 06:12:56 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-10-12 06:12:56 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-10-12 06:12:56 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:12:56 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-10-12 06:12:56 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:12:59 normalization > Running with dbt=1.0.0
2022-10-12 06:12:59 normalization > Partial parse save file not found. Starting full parse.
2022-10-12 06:13:02 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
There are 1 unused configuration paths:
- models.airbyte_utils.generated.airbyte_tables

2022-10-12 06:13:02 normalization > Found 5 models, 0 tests, 0 snapshots, 0 analyses, 593 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-10-12 06:13:06 normalization > Concurrency: 5 threads (target='prod')
2022-10-12 06:13:06 normalization > 1 of 3 START view model _AIRBYTE_TEST_APP_myschema.TEST_mytable_STG........................................... [RUN]
2022-10-12 06:13:08 normalization > 1 of 3 OK created view model _AIRBYTE_TEST_APP_myschema.TEST_mytable_STG...................................... [SUCCESS 1 in 1.42s]
2022-10-12 06:13:08 normalization > 2 of 3 START incremental model TEST_APP_myschema.TEST_mytable_SCD............................................. [RUN]
2022-10-12 06:13:09 normalization > 06:13:09 + "MY_DB".TEST_APP_myschema."TEST_mytable_SCD"._AIRBYTE_AB_ID does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-10-12 06:13:23 normalization > 2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
2022-10-12 06:13:23 normalization > 3 of 3 SKIP relation TEST_APP_myschema.TEST_mytable........................................................... [SKIP]
2022-10-12 06:13:23 normalization > Finished running 1 view model, 2 incremental models in 20.96s.
2022-10-12 06:13:23 normalization > Completed with 1 error and 0 warnings:
2022-10-12 06:13:23 normalization > Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
2022-10-12 06:13:23 normalization >   100038 (22018): Numeric value 'false' is not recognized
2022-10-12 06:13:23 normalization >   compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql
2022-10-12 06:13:23 normalization > Done. PASS=1 WARN=0 ERROR=1 SKIP=1 TOTAL=3
2022-10-12 06:13:23 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:23 normalization > Diagnosing dbt debug to check if destination is available for dbt and well configured (1):
2022-10-12 06:13:23 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:25 normalization > 06:13:25  Running with dbt=1.0.0
2022-10-12 06:13:25 normalization > dbt version: 1.0.0
2022-10-12 06:13:25 normalization > python version: 3.9.9
2022-10-12 06:13:25 normalization > python path: /usr/local/bin/python
2022-10-12 06:13:25 normalization > os info: Linux-4.14.287-148.504.amzn1.x86_64-x86_64-with-glibc2.31
2022-10-12 06:13:25 normalization > Using profiles.yml file at /data/48424/0/normalize/profiles.yml
2022-10-12 06:13:25 normalization > Using dbt_project.yml file at /data/48424/0/normalize/dbt_project.yml
2022-10-12 06:13:25 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:25 normalization > Configuration:
2022-10-12 06:13:25 normalization >   profiles.yml file [OK found and valid]
2022-10-12 06:13:25 normalization >   dbt_project.yml file [OK found and valid]
2022-10-12 06:13:25 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:25 normalization > Required dependencies:
2022-10-12 06:13:26 normalization >  - git [OK found]
2022-10-12 06:13:26 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:26 normalization > Connection:
2022-10-12 06:13:26 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:26 normalization > All checks passed!
2022-10-12 06:13:27 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:27 normalization > Forward dbt output logs to diagnose/debug errors (0):
2022-10-12 06:13:27 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-10-12 06:13:27 normalization > Running with dbt=1.0.0
2022-10-12 06:13:27 normalization > Partial parse save file not found. Starting full parse.
2022-10-12 06:13:27 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
There are 1 unused configuration paths:
- models.airbyte_utils.generated.airbyte_tables

2022-10-12 06:13:27 normalization > Found 5 models, 0 tests, 0 snapshots, 0 analyses, 593 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-10-12 06:13:27 normalization > Concurrency: 5 threads (target='prod')
2022-10-12 06:13:27 normalization > 1 of 3 START view model _AIRBYTE_TEST_APP_myschema.TEST_mytable_STG........................................... [RUN]
2022-10-12 06:13:27 normalization > 1 of 3 OK created view model _AIRBYTE_TEST_APP_myschema.TEST_mytable_STG...................................... [SUCCESS 1 in 1.42s]
2022-10-12 06:13:27 normalization > 2 of 3 START incremental model TEST_APP_myschema.TEST_mytable_SCD............................................. [RUN]
2022-10-12 06:13:27 normalization > 06:13:09 + "MY_DB".TEST_APP_myschema."TEST_mytable_SCD"._AIRBYTE_AB_ID does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-10-12 06:13:27 normalization > 2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
2022-10-12 06:13:27 normalization > 3 of 3 SKIP relation TEST_APP_myschema.TEST_mytable........................................................... [SKIP]
2022-10-12 06:13:27 normalization > Finished running 1 view model, 2 incremental models in 20.96s.
2022-10-12 06:13:27 normalization > Completed with 1 error and 0 warnings:
2022-10-12 06:13:27 normalization > Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
2022-10-12 06:13:27 normalization >   100038 (22018): Numeric value 'false' is not recognized
2022-10-12 06:13:27 normalization >   compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql
2022-10-12 06:13:27 normalization > Done. PASS=1 WARN=0 ERROR=1 SKIP=1 TOTAL=3
2022-10-12 06:13:28 INFO i.a.w.g.DefaultNormalizationWorker(run):82 - Normalization executed in 39 seconds.
2022-10-12 06:13:28 ERROR i.a.w.g.DefaultNormalizationWorker(run):90 - Normalization Failed.
2022-10-12 06:13:28 INFO i.a.w.g.DefaultNormalizationWorker(run):95 - Normalization summary: io.airbyte.config.NormalizationSummary@283fce45[startTime=1665555169187,endTime=1665555208944,failures=[io.airbyte.config.FailureReason@121abc57[failureOrigin=normalization,failureType=system_error,internalMessage=100038 (22018): Numeric value 'false' is not recognized,externalMessage=Normalization failed during the dbt run. This may indicate a problem with the data itself.,metadata=io.airbyte.config.Metadata@2acc1a0f[additionalProperties={attemptNumber=0, jobId=48424, from_trace_message=true}],stacktrace=AirbyteDbtError:
2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
  100038 (22018): Numeric value 'false' is not recognized
  compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql
2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
  100038 (22018): Numeric value 'false' is not recognized
  compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql,retryable=<null>,timestamp=1665555208942], io.airbyte.config.FailureReason@7c298027[failureOrigin=normalization,failureType=system_error,internalMessage=100038 (22018): Numeric value 'false' is not recognized,externalMessage=Normalization failed during the dbt run. This may indicate a problem with the data itself.,metadata=io.airbyte.config.Metadata@2ab22401[additionalProperties={attemptNumber=0, jobId=48424, from_trace_message=true}],stacktrace=AirbyteDbtError:
2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
  100038 (22018): Numeric value 'false' is not recognized
  compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql
2 of 3 ERROR creating incremental model TEST_APP_myschema.TEST_mytable_SCD.................................... [ERROR in 14.95s]
Database Error in model TEST_mytable_SCD (models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql)
  100038 (22018): Numeric value 'false' is not recognized
  compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/scd/my_schema/TEST_mytable_SCD.sql,retryable=<null>,timestamp=1665555208942]]]
2022-10-12 06:13:28 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-10-12 06:13:28 INFO i.a.c.i.LineGobbler(voidCall):114 -
2022-10-12 06:13:28 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):280 - Stopping temporal heartbeating...
2022-10-12 06:13:28 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION -----
2022-10-12 06:13:28 INFO i.a.c.i.LineGobbler(voidCall):114 -