Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Out of memory error when using S3 as staging storage for Snowflake #5277

Closed
rparrapy opened this issue Aug 9, 2021 · 13 comments · Fixed by #7074
Closed

Out of memory error when using S3 as staging storage for Snowflake #5277

rparrapy opened this issue Aug 9, 2021 · 13 comments · Fixed by #7074
Labels
area/connectors Connector related issues connectors/destination/snowflake connectors/destinations-warehouse priority/high High priority type/bug Something isn't working

Comments

@rparrapy
Copy link
Contributor

rparrapy commented Aug 9, 2021

Enviroment

  • Airbyte version: example is 0.29.1-alpha
  • OS Version / Instance: t2.xlarge
  • Deployment: Docker
  • Source Connector and version: MySQL 0.4.0
  • Destination Connector and version: Snowflake 0.3.11
  • Severity: Medium
  • Step where error happened: Sync job

Current Behavior

Enabling AWS S3 staging for the Snowflake destination results in out of memory errors. Standard inserts work but a 12 GB sync takes 3+ hours.

Expected Behavior

MySQL to Snowflake sync with S3 as staging storage works and is faster than standard inserts.

Logs

LOG

logs-sugar-s3.txt

Steps to Reproduce

  1. Set up MySQL source with large database (12 GB)
  2. Set up Snowflake destination with S3 as staging
  3. Sync

Are you willing to submit a PR?

No
@rparrapy rparrapy added the type/bug Something isn't working label Aug 9, 2021
@marcosmarxm marcosmarxm added the area/connectors Connector related issues label Aug 9, 2021
@danieldiamond
Copy link
Contributor

OS Version / Instance: Linux EC2 m5.2xlarge <-- doubled up
**Deployment: **Docker
Airbyte Version: 0.29.7-alpha
Source name: MySQL 0.4.3
destination: Snowflake 0.3.12

Logs

LOG 
2021-08-19 14:04:07 INFO () WorkerRun(call):62 - Executing worker wrapper. Airbyte version: 0.29.7-alpha
2021-08-19 14:04:07 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.29.7-alpha
2021-08-19 14:04:07 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 6635 attempt id: 0
2021-08-19 14:04:07 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {myschema.mytable=incremental - append}
2021-08-19 14:04:07 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-08-19 14:04:07 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-snowflake:0.3.12 exists...
2021-08-19 14:04:07 INFO () LineGobbler(voidCall):85 - airbyte/destination-snowflake:0.3.12 was found locally.
2021-08-19 14:04:07 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/6635/0 --network host --log-driver none airbyte/destination-snowflake:0.3.12 write --config destination_config.json --catalog destination_catalog.json
2021-08-19 14:04:07 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-mysql:0.4.3 exists...
2021-08-19 14:04:07 INFO () LineGobbler(voidCall):85 - airbyte/source-mysql:0.4.3 was found locally.
2021-08-19 14:04:07 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/6635/0 --network host --log-driver none airbyte/source-mysql:0.4.3 read --config source_config.json --catalog source_catalog.json --state input_state.json
2021-08-19 14:04:07 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-08-19 14:04:07 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-08-19 14:04:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.s.m.MySqlSource(main):249 - {} - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.d.s.SnowflakeDestination(main):81 - {} - starting destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.source.mysql.MySqlSource
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):100 - {} - Command: WRITE
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):100 - {} - Command: READ
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):101 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):101 - {} - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.d.j.c.SwitchingDestination(getConsumer):83 - {} - Using destination type: COPY_S3
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.s.r.CdcStateManager(<init>):46 - {} - Initialized CDC state with: null
2021-08-19 14:04:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:12 �[32mINFO�[m i.a.i.s.r.StateManager(createCursorInfoForStream):137 - {} - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='mytable', namespace='myschema'}, New Cursor Field: timemodified. Resetting cursor value
2021-08-19 14:04:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:13 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-08-19 14:04:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:13 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with full ID RpksCKowzrzo9.xvv4Lv5XrPM1x0H1qY9TneDeolfG08ERanJsMi516nIwP6sSeUCtVhbqexpifAS.NkiRSpZlHi8f8PawS53zGDgX0ZBv0NPXgEqLHScYcHsEfgy0bd
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):142 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(targetPosition):81 - {} - Target File position : FileName: mysql-bin-changelog.138819, Position : 2396160
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.a.i.d.AirbyteDebeziumHandler(getIncrementalIterators):92 - {} - using CDC: true
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m o.a.k.c.c.AbstractConfig(logAll):354 - {} - EmbeddedConfig values: 

...
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2021-08-19 14:04:14 INFO () JsonSchemaValidator(test):76 - JSON schema validation failed. 
errors: $: unknown found, object expected
2021-08-19 14:04:14 ERROR () DefaultAirbyteStreamFactory(lambda$create$1):83 - Validation failed: null
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m o.a.k.c.r.WorkerConfig(logPluginPathConfigProviderWarning):420 - {} - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {} - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(start):100 - {} - Starting MySqlConnectorTask with configuration:
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    connector.class = io.debezium.connector.mysql.MySqlConnector
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    snapshot.locking.mode = none
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.history.file.filename = /tmp/cdc-db-history5224031762927363281/dbhistory.dat
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.user = user
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.dbname = myschema
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    boolean.type = io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.server.name = myschema
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    include.schema.changes = false
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.port = 3306
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    offset.flush.interval.ms = 1000
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    key.converter.schemas.enable = false
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    offset.storage.file.filename = /tmp/cdc-state-offset890889218107926607/offset.dat
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    decimal.handling.mode = string
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.hostname = DB
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.password = ********
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    name = myschema
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    value.converter.schemas.enable = false
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    converters = boolean, datetime
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    datetime.type = io.airbyte.integrations.debezium.internals.MySQLDateTimeConverter
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    table.include.list = myschema.mytable
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    snapshot.mode = initial
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.history = io.airbyte.integrations.debezium.internals.FilteredFileDatabaseHistory
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.c.BaseSourceTask(lambda$start$0):102 - {} -    database.include.list = myschema
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[33mWARN�[m i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead.
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.MySqlConnectorTask(start):168 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Found no existing offset, so preparing to perform a snapshot
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.u.Threads(threadFactory):270 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Requested thread factory for connector MySqlConnector, id = myschema named = binlog-client
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.u.Threads(threadFactory):270 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Requested thread factory for connector MySqlConnector, id = myschema named = snapshot
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.u.Threads$3(newThread):287 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Creating thread debezium-mysqlconnector-myschema-snapshot
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):248 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Starting snapshot for jdbc:mysql://DB:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'user' with locking mode 'none'
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(logRolesForCurrentUser):1021 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Snapshot is using user 'user' with these MySQL grants:
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logRolesForCurrentUser$21):1022 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	GRANT SELECT, RELOAD, LOCK TABLES, EXECUTE, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user'@'%'
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(logServerInformation):992 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - MySQL server variables related to change data capture:
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_cache_size                             = 32768                                        
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_checksum                               = NONE                                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_direct_non_transactional_updates       = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_error_action                           = ABORT_SERVER                                 
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_format                                 = ROW                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_group_commit_sync_delay                = 0                                            
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_group_commit_sync_no_delay_count       = 0                                            
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_gtid_simple_recovery                   = ON                                           
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_max_flush_queue_time                   = 0                                            
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_order_commits                          = ON                                           
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_row_image                              = FULL                                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_rows_query_log_events                  = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_stmt_cache_size                        = 32768                                        
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_transaction_dependency_history_size    = 25000                                        
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	binlog_transaction_dependency_tracking        = COMMIT_ORDER                                 
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_client                          = utf8mb4                                      
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_connection                      = utf8mb4                                      
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_database                        = utf8mb4                                      
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_filesystem                      = binary                                       
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_results                         = utf8mb4                                      
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_server                          = latin1                                       
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_set_system                          = utf8                                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	character_sets_dir                            = /rdsdbbin/mysql-5.7.33.R2/share/charsets/    
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	collation_connection                          = utf8mb4_general_ci                           
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	collation_database                            = utf8mb4_unicode_520_ci                       
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	collation_server                              = latin1_swedish_ci                            
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	enforce_gtid_consistency                      = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_executed                                 =                                              
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_executed_compression_period              = 1000                                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_mode                                     = OFF_PERMISSIVE                               
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_next                                     = AUTOMATIC                                    
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_owned                                    =                                              
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	gtid_purged                                   =                                              
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	innodb_api_enable_binlog                      = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	innodb_locks_unsafe_for_binlog                = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	innodb_version                                = 5.7.33                                       
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	log_statements_unsafe_for_binlog              = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	max_binlog_cache_size                         = 18446744073709547520                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	max_binlog_size                               = 134217728                                    
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	max_binlog_stmt_cache_size                    = 18446744073709547520                         
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	protocol_version                              = 10                                           
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	session_track_gtids                           = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	slave_type_conversions                        =                                              
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	sync_binlog                                   = 1                                            
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	system_time_zone                              = UTC                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	time_zone                                     = UTC                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	tls_version                                   = TLSv1,TLSv1.1,TLSv1.2                        
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	tx_isolation                                  = REPEATABLE-READ                              
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	tx_read_only                                  = OFF                                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	version                                       = 5.7.33-log                                   
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	version_comment                               = Source distribution                          
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	version_compile_machine                       = x86_64                                       
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$logServerInformation$19):995 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	version_compile_os                            = Linux                                        
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):282 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 0: disabling autocommit, enabling repeatable read transactions, and setting lock wait timeout to 10
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):342 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 2: start transaction with consistent snapshot
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):367 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 3: read list of available databases
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):375 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	 list of available databases is: [...]
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):386 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 4: read list of available tables in each database
...
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$4):417 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	 'sys.sys_config' is filtered out of capturing
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):448 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	snapshot continuing with database(s): [myschema]
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(readBinlogPosition):906 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 5: read binlog position of MySQL primary server
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$readBinlogPosition$18):918 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - 	 using binlog 'mysql-bin-changelog.138819' at position '2397106' and gtid ''
2021-08-19 14:04:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:14 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):494 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 6: generating DROP and CREATE statements to reflect current database schemas:
2021-08-19 14:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:17 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):595 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: scanning contents of 1 tables while still in transaction
2021-08-19 14:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:17 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):646 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - scanning table 'myschema.mytable' (1 of 1 tables)
2021-08-19 14:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:17 �[32mINFO�[m i.d.c.m.SnapshotReader(execute):651 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - For table 'myschema.mytable' using select statement: 'SELECT * FROM `myschema`.`mytable`'
2021-08-19 14:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:17 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 10000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:00.568
2021-08-19 14:04:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 1000
2021-08-19 14:04:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 2000
2021-08-19 14:04:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 3000
2021-08-19 14:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:18 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 20000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:01.552
2021-08-19 14:04:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 4000
2021-08-19 14:04:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 5000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 6000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 7000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 8000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 9000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 10000
2021-08-19 14:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 11000
2021-08-19 14:04:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:19 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 30000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:02.328
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 12000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 13000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 14000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 15000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 16000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 17000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 18000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 19000
2021-08-19 14:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 20000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 21000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 22000
2021-08-19 14:04:21 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:20 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 40000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:03.725
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 23000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 24000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 25000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 26000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 27000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 28000
2021-08-19 14:04:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 29000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 30000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 31000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 32000
2021-08-19 14:04:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:21 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 50000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:04.852
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 33000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 34000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 35000
2021-08-19 14:04:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:22 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 1 containing 10.01 MB]
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 36000
2021-08-19 14:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 37000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 38000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 39000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 40000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 41000
2021-08-19 14:04:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:23 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 60000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:06.026
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 42000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 43000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 44000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 45000
2021-08-19 14:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 46000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 47000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 48000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 49000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 50000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 51000
2021-08-19 14:04:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:24 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 70000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:07.16
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 52000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 53000
2021-08-19 14:04:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:24 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 2 containing 10.01 MB]
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 54000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 55000
2021-08-19 14:04:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 56000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 57000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 58000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 59000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 60000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 61000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 62000
2021-08-19 14:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:25 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 80000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:08.164
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 63000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 64000
2021-08-19 14:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 65000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 66000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 67000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 68000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 69000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 70000
2021-08-19 14:04:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:26 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 90000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:09.153
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 71000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 72000
2021-08-19 14:04:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:26 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 3 containing 10.01 MB]
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 73000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 74000
2021-08-19 14:04:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 75000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 76000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 77000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 78000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 79000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 80000
2021-08-19 14:04:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:27 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 100000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:10.105
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 81000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 82000
2021-08-19 14:04:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:27 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 4 containing 10.01 MB]
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 83000
2021-08-19 14:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 84000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 85000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 86000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 87000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 88000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 89000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 90000
2021-08-19 14:04:28 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:28 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 110000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:11.197
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 91000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 92000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 93000
2021-08-19 14:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 94000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 95000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 96000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 97000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 98000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 99000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 100000
2021-08-19 14:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:29 �[32mINFO�[m i.d.c.m.SnapshotReader(lambda$execute$16):677 - {dbz.connectorContext=snapshot, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Step 7: - 120000 of 116584616 rows scanned from table 'myschema.mytable' after 00:00:12.197
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 101000
2021-08-19 14:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 14:04:29 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 5 containing 10.01 MB]
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 102000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 103000
2021-08-19 14:04:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 104000
2021-08-19 14:04:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 105000
2021-08-19 14:04:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 106000
2021-08-19 14:04:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 107000
2021-08-19 14:04:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 108000
...
...
..
2021-08-19 17:21:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121036000
2021-08-19 17:21:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121037000
2021-08-19 17:21:39 ERROR () LineGobbler(voidCall):85 - Aug 19, 2021 5:21:39 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2021-08-19 17:21:39 ERROR () LineGobbler(voidCall):85 - INFO: Connected to DB:3306 at mysql-bin-changelog.138819/2397106 (sid:5843, cid:681671)
2021-08-19 17:21:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121038000
2021-08-19 17:21:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.c.m.ChainedReader(startNextReader):201 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Transitioning from the snapshot reader to the binlog reader
2021-08-19 17:21:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.c.m.BinlogReader(doStart):367 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - GTID set purged on server: 
2021-08-19 17:21:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.u.Threads$3(newThread):287 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Creating thread debezium-mysqlconnector-myschema-binlog-client
2021-08-19 17:21:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.u.Threads$3(newThread):287 - {} - Creating thread debezium-mysqlconnector-myschema-binlog-client
2021-08-19 17:21:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121039000
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121040000
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.c.m.BinlogReader$ReaderThreadLifecycleListener(onConnect):1128 - {dbz.connectorContext=binlog, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Connected to MySQL binlog at DB:3306, starting at binlog file 'mysql-bin-changelog.138819', pos=2397106, skipping 0 events plus 0 rows
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.c.m.BinlogReader(doStart):415 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Waiting for keepalive thread to start
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.u.Threads$3(newThread):287 - {dbz.connectorContext=binlog, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Creating thread debezium-mysqlconnector-myschema-binlog-client
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121041000
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:39 �[32mINFO�[m i.d.c.m.BinlogReader(doStart):422 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Keepalive thread is running
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121042000
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:40 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/b4719eea-f4ba-4723-b502-45f7b1e5a7c7/app_myschema/mytable with id RpksCKowz...HsEfgy0bd]: Finished uploading [Part number 6941 containing 10.01 MB]
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121043000
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121044000
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121045000
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121046000
2021-08-19 17:21:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 121047000
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2397106 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:40 �[32mINFO�[m i.d.e.EmbeddedEngine(stop):996 - {} - Stopping the embedded engine
2021-08-19 17:21:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:40 �[32mINFO�[m i.d.e.EmbeddedEngine(stop):1004 - {} - Waiting for PT5M for connector to stop
2021-08-19 17:21:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:41 �[32mINFO�[m i.d.c.c.BaseSourceTask(stop):192 - {} - Stopping down connector
2021-08-19 17:21:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:41 �[32mINFO�[m i.d.c.m.MySqlConnectorTask(doStop):453 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Stopping MySQL connector task
2021-08-19 17:21:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:41 �[32mINFO�[m i.d.c.m.ChainedReader(stop):121 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - ChainedReader: Stopping the binlog reader
2021-08-19 17:21:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:21:41 �[32mINFO�[m i.d.c.m.AbstractReader(stop):140 - {dbz.connectorContext=task, dbz.connectorName=myschema, dbz.connectorType=MySQL} - Discarding 156 unsent record(s) due to the connector shutting down
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2401593 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2432352 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2436971 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2450413 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2457952 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2462176 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2462944 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2465847 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2471032 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2482022 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2484054 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2494631 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2495001 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2496707 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2511869 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2535174 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2543436 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2559060 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2563406 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2577989 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2585402 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2593801 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2595831 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2604432 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2604812 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2610558 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2611523 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2612633 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2617243 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2619602 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2622789 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2628800 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2639508 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2650001 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2657456 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2663279 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2673841 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2674556 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2675318 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2676080 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2679126 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2680269 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2685529 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2690681 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2692433 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2697630 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2700121 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2700981 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2703254 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138819 , position : 2704397 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 943 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 6133 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 7663 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 9402 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 10441 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 18477 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 25256 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 31613 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 37329 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 41302 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 57442 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 65327 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 73612 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 81121 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 85894 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 86616 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 94622 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 101168 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 104609 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 114061 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 115086 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 116229 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 121858 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 124041 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 133430 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 139632 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 141280 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 150172 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 155915 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 160100 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 166154 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 169294 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 172760 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 174221 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 177538 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 177918 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 187089 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 190427 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 195025 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 213682 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 218052 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 228096 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 232498 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 248607 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 250078 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 253903 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 262528 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 263695 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 275251 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 275968 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 288085 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 295231 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 302112 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 311996 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 324283 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 325369 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 334451 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 338100 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 339558 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 346702 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 355349 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 358212 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 364392 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 368817 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 381017 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 393004 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 393775 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 398607 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 407588 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 416162 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 417800 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 427684 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 438812 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 441000 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 442923 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 446291 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 447155 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 463947 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 473737 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 484977 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 493182 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 502964 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 519833 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 528338 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 532298 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 540219 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 549184 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 559853 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 562477 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 578766 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 582979 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 587053 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 601623 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 620360 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 627069 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 628285 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 629665 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 632553 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 635448 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 637543 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 640210 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 645638 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 648623 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 659724 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 671118 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 673281 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 678005 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 684539 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 685306 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 707005 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 709497 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 710564 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 715401 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 719546 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 729154 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 732026 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 733754 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 734609 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 739602 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 741430 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 742295 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 748230 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 749879 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 758746 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 765002 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 769896 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 778768 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 779633 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 787347 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 788906 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 793475 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 810870 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 826137 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 838912 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 845554 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 848939 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 850611 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 851742 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 853390 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 859622 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 860764 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 863121 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 866125 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 868341 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 876165 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 884122 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 885605 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 892874 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 895557 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 906929 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 912524 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 919204 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 919584 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 925706 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:40 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138820 , position : 934056 is after target file : mysql-bin-changelog.138819 , target position : 2396160

...
..
...
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2419899 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2423962 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2428783 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2440203 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2444594 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2449180 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2450537 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2459160 is after target file : mysql-bin-changelog.138819 , target position : 2396160
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlCdcTargetPosition(reachedTargetPosition):103 - {} - Signalling close because record's binlog file : mysql-bin-changelog.138829 , position : 2460771 is after target file : mysql-bin-changelog.138819 , target position : 2396160
...
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):200 - {} - Closing database connection pool.
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):202 - {} - Closed database connection pool.
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):153 - {} - Completed integration: io.airbyte.integrations.source.mysql.MySqlSource
2021-08-19 17:36:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-08-19 17:36:41 �[32mINFO�[m i.a.i.s.m.MySqlSource(main):251 - {} - completed source: class io.airbyte.integrations.source.mysql.MySqlSource

@danieldiamond
Copy link
Contributor

@sherifnada any chance there's capacity for this one?

This was referenced Aug 20, 2021
Closed
Closed
@etsybaev
Copy link
Contributor

etsybaev commented Sep 3, 2021 •
edited
Loading

HI @rparrapy. Many thanks for reporting this issue and for your interest in the product. Could you please provide a little bit more info about your env where you migrated data? many many streams\rows\records? How much ram and heap memory had been allocated to the container when it failed? Did you try to allocate more memory? Many thanks in advance!

@etsybaev
Copy link
Contributor

etsybaev commented Sep 5, 2021

Just a hint for those who will work on it.

As an option, you may try to use this LoadTest. Just add it to the DestinationAcceptanceTest

`
@test
// @disabled
public void testSyncLong() throws Exception {
final int streamsSize = 5; // number of generated streams
final int messagesNumber = 300000000; // number of msg to be written to each generated stream

final String USERS_STREAM_NAME = "users"; // stream's prefix
final String ID = "id";
final String NAME = "name";

// generate schema\catalogs
List<AirbyteStream> configuredAirbyteStreams = new ArrayList<>();
for (int i = 0; i < streamsSize; i++) {
  configuredAirbyteStreams
      .add(CatalogHelpers.createAirbyteStream(USERS_STREAM_NAME + i,
          Field.of(NAME, JsonSchemaPrimitive.STRING),
          Field
              .of(ID, JsonSchemaPrimitive.STRING)));
}
final AirbyteCatalog testCatalog = new AirbyteCatalog().withStreams(configuredAirbyteStreams);
final ConfiguredAirbyteCatalog configuredTestCatalog = CatalogHelpers
    .toDefaultConfiguredCatalog(testCatalog);

final JsonNode config = getConfig();
final WorkerDestinationConfig destinationConfig = new WorkerDestinationConfig()
    .withConnectionId(UUID.randomUUID())
    .withCatalog(configuredTestCatalog)
    .withDestinationConnectionConfiguration(config);
final AirbyteDestination destination = getDestination();

//Start destination
destination.start(destinationConfig, jobRoot);

AtomicInteger currentStreamNumber = new AtomicInteger(0);
AtomicInteger currentRecordNumberForStream = new AtomicInteger(0);

// this is just a logger. Useful when running long hours tests
Thread countPrinter = new Thread(() -> {
  while (true) {
    System.out.println(
        "currentStreamNumber=" + currentStreamNumber + ", currentRecordNumberForStream="
            + currentRecordNumberForStream);
    try {
      Thread.sleep(10000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }

});
countPrinter.start();

// iterate through streams
for (int streamCounter = 0; streamCounter < streamsSize; streamCounter++) {
  LOGGER.info("Started new stream processing with #" + streamCounter);
  //iterate through msm inside a particular stream
  // Generate messages and put it to stream
  for (int msgCounter = 0; msgCounter < messagesNumber; msgCounter++) {
    AirbyteMessage msg = new AirbyteMessage()
        .withType(AirbyteMessage.Type.RECORD)
        .withRecord(new AirbyteRecordMessage().withStream(USERS_STREAM_NAME + streamCounter)
            .withData(
                Jsons.jsonNode(
                    ImmutableMap.builder().put(NAME, LOREM_IPSUM)
                        .put(ID, streamCounter + "_" + msgCounter)
                        .build()))
            .withEmittedAt(Instant.now().toEpochMilli()));
    try {
      destination.accept(msg);
    } catch (Exception e) {
      LOGGER.error("Failed to write a RECORD message: " + e);
      throw new RuntimeException(e);
    }

    //send state message here, it's required
    AirbyteMessage msgState = new AirbyteMessage()
        .withType(AirbyteMessage.Type.STATE)
        .withState(new AirbyteStateMessage()
            .withData(
                Jsons.jsonNode(ImmutableMap.builder().put("checkpoint", "now!").build())));
    try {
      destination.accept(msgState);
    } catch (Exception e) {
      LOGGER.error("Failed to write a STATE message: " + e);
      throw new RuntimeException(e);
    }
    currentRecordNumberForStream.set(msgCounter);
  }
  currentStreamNumber.set(streamCounter);
}

LOGGER.info(String
    .format("Added %s messages to each of %s streams", currentRecordNumberForStream,
        currentStreamNumber));
// Close destination
destination.notifyEndOfStream();

}`

@rparrapy
Copy link
Contributor Author

rparrapy commented Sep 6, 2021

Hi @etsybaev ! I believe this issue to be related to this: #3439
Basically, the issue is not the number of rows but the fact that rows themselves are memory-hungry.

As for RAM and heap memory, all I know is I used a t2.xlarge and the default Airbyte settings. Not sure what the defaults are for RAM and heap memory are.

@marcosmarxm marcosmarxm added the priority/high High priority label Oct 15, 2021
@marcosmarxm
Copy link
Member

Another slack convo with same problem.

Hey guys, we are currently trying to get airbyte working with our MySQL -> Snowflake setting. The problem here is that the performance is very bad. We did already use a CloudMySQL instance to ensure our Database is not the bottleneck. But even there the Full Load of a small 5GB (20 million rows) MySQL DB takes about 2 hours. In comparsion other ETL tools do it in 15 min. I would like to increase the batch size for this converter, which is by default 10k. Does anyone know how to change that? Any other ideas, how to get it faster?
Setup:
Deployment: Docker (AWS c5 instance)
Airbyte Version: 0.30.20-alpha
Source name/version: MySQL 0.4.6
Destination name/version: Snowflake (0.3.14)
So I used S3 staging and it's is much faster.
But it throws a OutOfMemory Error. However it does not recognize that error and continues with the data loaded so far (so basically incomplete data). Just to fail again later when loading the the staged files into snowflake. It's ridiculous.
2021-10-15 10:43:44 ERROR a.m.s.StreamTransferManager(abort):432 - {} - Aborting [Manager uploading to s3.airbyte/64855650-cbf0-4d84-b75f-04098aff3f4b/tpcds/259_vywyt_inventory with id nDamEsOOY...TpoUkYsyR] due to error: java.lang.OutOfMemoryError: Java heap space

@andriikorotkov andriikorotkov linked a pull request Oct 18, 2021 that will close this issue
🐛 fixed OOM error when splitting a stream into several files #7074
Merged
38 tasks
@andriikorotkov andriikorotkov self-assigned this Oct 18, 2021
@andriikorotkov
Copy link
Contributor

@marcosmarxm, I published a new version of the snowflake (0.3.16), in which this bug was fixed. Please try running your connector again and make sure the bug is not reproduced.

@danieldiamond
Copy link
Contributor

🚀 🚀 🚀 🚀 @andriikorotkov looking good so far. my 60M records table, which previously would hang, has successfully loaded using CDC + S3 staging.

@danieldiamond
Copy link
Contributor

danieldiamond commented Oct 19, 2021 •
edited
Loading

updating: now tried it with multiple tables and unfortunately back at the issue where the sync hangs. reset entire connector ~250M rows 👎

@danieldiamond
Copy link
Contributor 

CONTAINER ID   NAME                 CPU %     MEM USAGE / LIMIT     MEM %     NET I/O           BLOCK I/O         PIDS
b5c61934202f   recursing_margulis   100.25%   2.821GiB / 30.96GiB   9.11%     0B / 0B           240MB / 3.63GB    42
14dc4b2f7d4c   elated_wilbur        0.15%     1.667GiB / 30.96GiB   5.38%     0B / 0B           228MB / 0B        369
73c72f499fb1   airbyte-server       0.08%     1.12GiB / 30.96GiB    3.62%     57.1GB / 6.09GB   355MB / 0B        176
2e5b9bfef778   airbyte-scheduler    0.04%     694.5MiB / 30.96GiB   2.19%     198GB / 2.28GB    307MB / 0B        59
e301c04538d1   airbyte-db           0.00%     231.7MiB / 30.96GiB   0.73%     4.11GB / 256GB    53.4MB / 209kB    50
f1deb8ddd649   airbyte-webapp       0.00%     13.17MiB / 30.96GiB   0.04%     5.02GB / 5.04GB   31.9MB / 12.3kB   9
0119fd378f23   airbyte-worker       0.07%     2.248GiB / 30.96GiB   7.26%     352MB / 295MB     535MB / 0B        138
81778d3d754e   airbyte-temporal     0.99%     228.4MiB / 30.96GiB   0.72%     1.31GB / 2.01GB   404MB / 24.6kB    17

CONTAINER ID   IMAGE                                  COMMAND                  CREATED       STATUS                  PORTS                                                                                         NAMES
b5c61934202f   airbyte/source-mysql:0.4.8             "/airbyte/base.sh re…"   7 hours ago   Up 7 hours                                                                                                            recursing_margulis
14dc4b2f7d4c   airbyte/destination-snowflake:0.3.16   "/airbyte/base.sh wr…"   7 hours ago   Up 7 hours                                                                                                            elated_wilbur
73c72f499fb1   airbyte/server:0.30.20-alpha           "/bin/bash -c bin/${…"   4 days ago    Up 4 days               8000/tcp, 0.0.0.0:8001->8001/tcp, :::8001->8001/tcp                                           airbyte-server
2e5b9bfef778   airbyte/scheduler:0.30.20-alpha        "/bin/bash -c bin/${…"   4 days ago    Up 4 days                                                                                                             airbyte-scheduler
e301c04538d1   airbyte/db:0.30.20-alpha               "docker-entrypoint.s…"   4 days ago    Up 4 days               5432/tcp                                                                                      airbyte-db
f1deb8ddd649   airbyte/webapp:0.30.20-alpha           "/docker-entrypoint.…"   4 days ago    Up 4 days               0.0.0.0:8000->80/tcp, :::8000->80/tcp                                                         airbyte-webapp
0119fd378f23   airbyte/worker:0.30.20-alpha           "/bin/bash -c bin/${…"   4 days ago    Up 4 days                                                                                                             airbyte-worker
ba4b42736bcb   airbyte/init:0.30.20-alpha             "/bin/sh -c './scrip…"   4 days ago    Exited (0) 4 days ago                                                                                                 init
81778d3d754e   temporalio/auto-setup:1.7.0            "/entrypoint.sh /bin…"   2 weeks ago   Up 4 days               6933-6935/tcp, 6939/tcp, 7234-7235/tcp, 7239/tcp, 0.0.0.0:7233->7233/tcp, :::7233->7233/tcp   airbyte-temporal

@andriikorotkov andriikorotkov removed their assignment Oct 19, 2021
@alexandr-shegeda
Copy link
Contributor

@danieldiamond could you possibly provide the latest connector log?

@alexandr-shegeda
Copy link
Contributor

it looks to me that the initial root cause with OOM was fixed in the scope of this ticket, but @danieldiamond was faced with another issue that was described in this ticket #6003
@sherifnada do you think we can close this issue and continue research in the scope of 6003?

@tuliren tuliren mentioned this issue Oct 19, 2021
Closed
@sherifnada
Copy link
Contributor

SGTM, the OOM sounds addressed, let's follow up on the CPU issue in the other thread. But let's make sure to move daniel's comments to the other thread as well to retain the context

@sherifnada sherifnada moved this to Done in GL Roadmap Jan 12, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
area/connectors Connector related issues connectors/destination/snowflake connectors/destinations-warehouse priority/high High priority type/bug Something isn't working
Projects
No open projects
GL Roadmap
Archived in project
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

🐛 fixed OOM error when splitting a stream into several files airbytehq/airbyte
8 participants
@rparrapy @etsybaev @marcosmarxm @sherifnada @alexandr-shegeda @karinakuz @danieldiamond @andriikorotkov