2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: must be a constant value STANDARD
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.private_key: is missing but it is required
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.password: object found, string expected
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Standard]
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Internal Staging]
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.access_key_id: object found, string expected, $.secret_access_key: object found, string expected
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [GCS Staging], $.project_id: is missing but it is required, $.bucket_name: is missing but it is required, $.credentials_json: is missing but it is required
2022-12-01 02:18:50 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Azure Blob Staging], $.azure_blob_storage_account_name: is missing but it is required, $.azure_blob_storage_container_name: is missing but it is required, $.azure_blob_storage_sas_token: is missing but it is required
2022-12-01 02:18:50 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/61219/0/logs.log
2022-12-01 02:18:50 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.18
2022-12-01 02:18:50 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-01 02:18:50 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1079 - Using default value for environment variable METRIC_CLIENT: ''
2022-12-01 02:18:50 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to
2022-12-01 02:18:50 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-01 02:18:50 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):133 - start sync worker. job id: 61219 attempt id: 0
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:18:50 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):149 - configured sync modes: {mydb.mytable_a=incremental - append_dedup, mydb.mytable_b=incremental - append_dedup}
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2022-12-01 02:18:50 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.40 exists...
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.40 was found locally.
2022-12-01 02:18:50 [32mINFO[m i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-write-61219-0-kpwrr with resources io.airbyte.config.ResourceRequirements@3fdf5ea2[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-01 02:18:50 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/61219/0 --log-driver none --name destination-snowflake-write-61219-0-kpwrr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.40 -e AIRBYTE_VERSION=0.40.18 -e WORKER_JOB_ID=61219 airbyte/destination-snowflake:0.4.40 write --config destination_config.json --catalog destination_catalog.json
2022-12-01 02:18:50 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2022-12-01 02:18:50 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mysql:1.0.14 exists...
2022-12-01 02:18:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mysql:1.0.14 was found locally.
2022-12-01 02:18:50 [32mINFO[m i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-mysql-read-61219-0-jbrby with resources io.airbyte.config.ResourceRequirements@6943d031[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-01 02:18:50 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/61219/0 --log-driver none --name source-mysql-read-61219-0-jbrby --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:1.0.14 -e AIRBYTE_VERSION=0.40.18 -e WORKER_JOB_ID=61219 airbyte/source-mysql:1.0.14 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-12-01 02:18:50 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-01 02:18:50 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):468 - Destination output thread started.
2022-12-01 02:18:50 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):197 - Waiting for source and destination threads to complete.
2022-12-01 02:18:50 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):353 - Replication thread started.
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running destination under deployment mode: OSS
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: READ
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: WRITE
2022-12-01 02:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Using destination type: COPY_S3
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting connection with method: NO_TUNNEL
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Global state manager selected to manage state object with type GLOBAL.
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: mydb_mytable_a. Cursor Field: null Value: null Count: 0
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: mydb_mytable_b. Cursor Field: null Value: null Count: 0

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting...
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating S3 client...
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed.
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=mytable_b, namespace=app_mydb, outputSchemaName=app_mydb, tmpTableName=_airbyte_tmp_kvr_mytable_b, outputTableName=_airbyte_raw_mytable_b, syncMode=append_dedup}
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=mytable_a, namespace=app_mydb, outputSchemaName=app_mydb, tmpTableName=_airbyte_tmp_lap_mytable_a, outputTableName=_airbyte_raw_mytable_a, syncMode=append_dedup}
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing tmp tables in destination started for 2 streams
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema app_mydb stream mytable_b: tmp table: _airbyte_tmp_kvr_mytable_b, stage: APP_mydb_mytable_b/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting...
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Internal schemas to exclude: [performance_schema, information_schema, mysql, sys]

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - First record waiting time: 300 seconds
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - First record waiting time: 300 seconds
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Target File position : FileName: mysql-bin-changelog.000002, Position : 55538315
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Using CDC: true
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values:
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = true

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - EmbeddedConfig values:
	access.control.allow.methods =
	access.control.allow.origin =
	admin.listeners = null
	bootstrap.servers = [localhost:9092]
	client.dns.lookup = use_all_dns_ips
	config.providers = []
	connector.client.config.override.policy = All
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	listeners = [http://:8083]
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	offset.flush.interval.ms = 1000
	offset.flush.timeout.ms = 5000
	offset.storage.file.filename = /tmp/cdc-state-offset7416984687068970499/offset.dat
	offset.storage.partitions = null
	offset.storage.replication.factor = null
	offset.storage.topic =
	plugin.path = null
	response.http.headers.config =
	rest.advertised.host.name = null
	rest.advertised.listener = null
	rest.advertised.port = null
	rest.extension.classes = []
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	task.shutdown.graceful.timeout.ms = 5000
	topic.creation.enable = true
	topic.tracking.allow.reset = true
	topic.tracking.enable = true
	value.converter = class org.apache.kafka.connect.json.JsonConverter

2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - The worker has been configured with one or more internal converter properties ([internal.key.converter, internal.value.converter]). Support for these properties was deprecated in version 2.0 and removed in version 3.0, and specifying them will have no effect. Instead, an instance of the JsonConverter with schemas.enable set to false will be used. For more information, please visit http://kafka.apache.org/documentation/#upgrade and consult the upgrade notesfor the 3.0 release.
2022-12-01 02:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - 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.
2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values:
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2022-12-01 02:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting FileOffsetBackingStore with file /tmp/cdc-state-offset7416984687068970499/offset.dat
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting MySqlConnectorTask with configuration:
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    connector.class = io.debezium.connector.mysql.MySqlConnector
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    snapshot.locking.mode = none
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    max.queue.size = 8192
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.history.consumer.security.protocol = SSL
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    include.schema.changes = false
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    binary.handling.mode = base64
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    offset.storage.file.filename = /tmp/cdc-state-offset7416984687068970499/offset.dat
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    decimal.handling.mode = string
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    converters = boolean, datetime
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    datetime.type = io.airbyte.integrations.debezium.internals.MySQLDateTimeConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    value.converter = org.apache.kafka.connect.json.JsonConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    key.converter = org.apache.kafka.connect.json.JsonConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.history.file.filename = /tmp/cdc-db-history6018752210170300493/dbhistory.dat
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.user = db-user
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.dbname = mydb
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.history.producer.security.protocol = SSL
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    boolean.type = io.airbyte.integrations.debezium.internals.CustomMySQLTinyIntOneToBooleanConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.server.name = mydb
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    offset.flush.timeout.ms = 5000
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.port = 3306
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    offset.flush.interval.ms = 1000
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    key.converter.schemas.enable = false
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.ssl.mode = PREFERRED
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    internal.key.converter = org.apache.kafka.connect.json.JsonConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.hostname = myhost.rds.amazonaws.com
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.password = ********
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    name = mydb
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    value.converter.schemas.enable = false
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    internal.value.converter = org.apache.kafka.connect.json.JsonConverter
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    max.batch.size = 2048
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    table.include.list = mydb.mytable_b,mydb.mytable_a
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    snapshot.mode = when_needed
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.history = io.debezium.relational.history.FileDatabaseHistory
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 -    database.include.list = mydb
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found previous partition offset MySqlPartition [sourcePartition={server=mydb}]: {transaction_id=null, file=mysql-bin-changelog.000002, pos=55521575}
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing connection before starting schema recovery
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Started database history recovery
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Finished database history recovery of 16 change(s) in 617 ms
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Reconnecting after finishing schema recovery
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Get all known binlogs from MySQL
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - MySQL has the binlog file 'mysql-bin-changelog.000002' required by the connector
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Requested thread factory for connector MySqlConnector, id = mydb named = change-event-source-coordinator
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-mysqlconnector-mydb-change-event-source-coordinator
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Metrics registered
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Context created
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@193bb809
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed.
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - A previous offset indicating a completed snapshot has been found. Neither schema nor data will be snapshotted.
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Snapshot ended with SnapshotResult [status=SKIPPED, offset=MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin-changelog.000002, currentBinlogPosition=55521575, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-bin-changelog.000002, restartBinlogPosition=55521575, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Requested thread factory for connector MySqlConnector, id = mydb named = binlog-client
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Enable ssl PREFERRED mode for connector mydb
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting streaming
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - GTID set purged on server:
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Skip 0 events on streaming start
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Skip 0 rows on streaming start
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-mysqlconnector-mydb-binlog-client
2022-12-01 02:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-mysqlconnector-mydb-binlog-client
2022-12-01 02:18:58 [44msource[0m > Dec 01, 2022 2:18:58 AM com.github.shyiko.mysql.binlog.BinaryLogClient tryUpgradeToSSL
2022-12-01 02:18:58 [44msource[0m > INFO: SSL enabled
2022-12-01 02:18:58 [44msource[0m > Dec 01, 2022 2:18:58 AM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2022-12-01 02:18:58 [44msource[0m > INFO: Connected to myhost.rds.amazonaws.com:3306 at mysql-bin-changelog.000002/55521575 (sid:6063, cid:1042)
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connected to MySQL binlog at myhost.rds.amazonaws.com:3306, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin-changelog.000002, currentBinlogPosition=55521575, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-bin-changelog.000002, restartBinlogPosition=55521575, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Waiting for keepalive thread to start
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-mysqlconnector-mydb-binlog-client
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Keepalive thread is running
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema app_mydb stream mytable_b
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema app_mydb stream mytable_a: tmp table: _airbyte_tmp_lap_mytable_a, stage: APP_mydb_mytable_a/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/
2022-12-01 02:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection
2022-12-01 02:18:59 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema app_mydb stream mytable_a
2022-12-01 02:18:59 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing tmp tables in destination completed.
2022-12-01 02:23:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing: queue returned null event
2022-12-01 02:23:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping the embedded engine
2022-12-01 02:23:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Waiting for PT5M for connector to stop
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping the task and engine
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping down connector
2022-12-01 02:23:57 [44msource[0m > Dec 01, 2022 2:23:57 AM com.github.shyiko.mysql.binlog.BinaryLogClient$5 run
2022-12-01 02:23:57 [44msource[0m > INFO: threadExecutor is shut down, terminating keepalive thread
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Finished streaming
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, file=mysql-bin-changelog.000002, pos=55521575, server_id=1173119459, event=1}
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopped FileOffsetBackingStore
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Debezium engine shutdown.
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - no record found. polling again.
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing: Iterator closing

2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing database connection pool.
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown initiated...
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown completed.
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closed database connection pool.
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-01 02:23:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - completed source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-12-01 02:23:58 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):386 - Source has no more messages, closing connection.
2022-12-01 02:23:58 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):395 - Total records read: 1 (0 bytes)
2022-12-01 02:23:58 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):202 - One of source or destination thread complete. Waiting on the other.
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Airbyte message consumer: succeeded.
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - executing on success close procedure.
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Flushing all 0 current buffers (0 bytes in total)
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying into tables in destination started for 2 streams
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream mytable_b of schema app_mydb into tmp table _airbyte_tmp_kvr_mytable_b to final table _airbyte_raw_mytable_b from stage path APP_mydb_mytable_b/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/ with 0 file(s) []
2022-12-01 02:23:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting copy to tmp table from stage: _airbyte_tmp_kvr_mytable_b in destination from stage: APP_mydb_mytable_b/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/, schema: app_mydb, .
2022-12-01 02:23:59 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copy to tmp table app_mydb._airbyte_tmp_kvr_mytable_b in destination complete.
2022-12-01 02:24:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream mytable_a of schema app_mydb into tmp table _airbyte_tmp_lap_mytable_a to final table _airbyte_raw_mytable_a from stage path APP_mydb_mytable_a/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/ with 0 file(s) []
2022-12-01 02:24:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting copy to tmp table from stage: _airbyte_tmp_lap_mytable_a in destination from stage: APP_mydb_mytable_a/2022/12/01/02/7175EB0E-3DCD-478D-9E43-6EC977C00845/, schema: app_mydb, .
2022-12-01 02:24:02 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copy to tmp table app_mydb._airbyte_tmp_lap_mytable_a in destination complete.
2022-12-01 02:24:02 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - No onDestinationCloseOperations required for this destination.
2022-12-01 02:24:02 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Executing finalization of tables.
2022-12-01 02:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Finalizing tables in destination completed.
2022-12-01 02:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning up destination started for 2 streams
2022-12-01 02:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream mytable_b. schema app_mydb, tmp table name: _airbyte_tmp_kvr_mytable_b
2022-12-01 02:24:04 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream mytable_a. schema app_mydb, tmp table name: _airbyte_tmp_lap_mytable_a
2022-12-01 02:24:04 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning up destination completed.

2022-12-01 02:24:04 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-12-01 02:24:04 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-12-01 02:24:07 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):204 - Source and destination threads complete.
2022-12-01 02:24:07 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):308 - Source output at least one state message

2022-12-01 02:24:07 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):329 - sync summary: {
  "status" : "completed",
  "recordsSynced" : 0,
  "bytesSynced" : 0,
  "startTime" : 1669861130573,
  "endTime" : 1669861447183,
  "totalStats" : {
    "recordsEmitted" : 0,
    "bytesEmitted" : 0,
    "sourceStateMessagesEmitted" : 1,
    "destinationStateMessagesEmitted" : 1,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 7,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 7,
    "replicationStartTime" : 1669861130573,
    "replicationEndTime" : 1669861447183,
    "sourceReadStartTime" : 1669861130641,
    "sourceReadEndTime" : 1669861438442,
    "destinationWriteStartTime" : 1669861130780,
    "destinationWriteEndTime" : 1669861447183
  },
  "streamStats" : [ ]
}
2022-12-01 02:24:07 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):330 - failures: [ ]
2022-12-01 02:24:07 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling...
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -

2022-12-01 02:24:07 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):191 - Sync summary length: 18631
2022-12-01 02:24:07 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2022-12-01 02:24:07 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2022-12-01 02:24:07 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/61219/0/logs.log
2022-12-01 02:24:07 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.18
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION -----
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:24:07 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(runProcess):134 - Running with normalization version: airbyte/normalization-snowflake:0.2.24
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-snowflake:0.2.24 exists...
2022-12-01 02:24:07 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-snowflake:0.2.24 was found locally.
2022-12-01 02:24:07 [32mINFO[m i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = normalization-snowflake-normalize-61219-0-wxddb with resources io.airbyte.config.ResourceRequirements@4e8257b0[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-01 02:24:07 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/61219/0/normalize --log-driver none --name normalization-snowflake-normalize-61219-0-wxddb --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.40.18 airbyte/normalization-snowflake:0.2.24 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-12-01 02:24:11 [42mnormalization[0m > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/61219/0/normalize
2022-12-01 02:24:11 [42mnormalization[0m > Namespace(config='destination_config.json', integration_type=<DestinationType.SNOWFLAKE: 'snowflake'>, out='/data/61219/0/normalize')
2022-12-01 02:24:11 [42mnormalization[0m > transform_snowflake
2022-12-01 02:24:11 [42mnormalization[0m > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/61219/0/normalize --catalog destination_catalog.json --out /data/61219/0/normalize/models/generated/ --json-column _airbyte_data
2022-12-01 02:24:12 [42mnormalization[0m > Processing destination_catalog.json...
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_ctes/APP_mydb/mytable_b_AB1.sql from mytable_b
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_ctes/APP_mydb/mytable_b_AB2.sql from mytable_b
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_views/APP_mydb/mytable_b_STG.sql from mytable_b
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_incremental/scd/APP_mydb/mytable_b_SCD.sql from mytable_b
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_incremental/APP_mydb/mytable_b.sql from mytable_b
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_ctes/APP_mydb/mytable_a_AB1.sql from mytable_a
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_ctes/APP_mydb/mytable_a_AB2.sql from mytable_a
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_views/APP_mydb/mytable_a_STG.sql from mytable_a
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_incremental/scd/APP_mydb/mytable_a_SCD.sql from mytable_a
2022-12-01 02:24:12 [42mnormalization[0m >   Generating airbyte_incremental/APP_mydb/mytable_a.sql from mytable_a
2022-12-01 02:24:12 [42mnormalization[0m > detected no config file for ssh, assuming ssh is off.
2022-12-01 02:24:14 [42mnormalization[0m >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-12-01 02:24:14 [42mnormalization[0m >   --event-buffer-size EVENT_BUFFER_SIZE
2022-12-01 02:24:14 [32mINFO[m i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-12-01 02:24:14 [42mnormalization[0m > DBT >=1.0.0 detected; using 10K event buffer size
2022-12-01 02:24:14 [32mINFO[m i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2022-12-01 02:24:17 [42mnormalization[0m > Running with dbt=1.0.0
2022-12-01 02:24:17 [42mnormalization[0m > Partial parse save file not found. Starting full parse.
2022-12-01 02:24:19 [42mnormalization[0m > [[33mWARNING[0m]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
There are 1 unused configuration paths:
- models.airbyte_utils.generated.airbyte_tables

2022-12-01 02:24:19 [42mnormalization[0m > Found 10 models, 0 tests, 0 snapshots, 0 analyses, 593 macros, 0 operations, 0 seed files, 2 sources, 0 exposures, 0 metrics
2022-12-01 02:24:23 [42mnormalization[0m > Concurrency: 5 threads (target='prod')
2022-12-01 02:24:23 [42mnormalization[0m > 1 of 6 START view model _AIRBYTE_APP_mydb.mytable_b_STG................................................................ [RUN]
2022-12-01 02:24:23 [42mnormalization[0m > 2 of 6 START view model _AIRBYTE_APP_mydb.mytable_a_STG................................................................. [RUN]
2022-12-01 02:24:25 [42mnormalization[0m > 1 of 6 OK created view model _AIRBYTE_APP_mydb.mytable_b_STG........................................................... [[32mSUCCESS 1[0m in 1.73s]
2022-12-01 02:24:25 [42mnormalization[0m > 2 of 6 OK created view model _AIRBYTE_APP_mydb.mytable_a_STG............................................................ [[32mSUCCESS 1[0m in 1.72s]
2022-12-01 02:24:25 [42mnormalization[0m > 3 of 6 START incremental model APP_mydb.mytable_b_SCD.................................................................. [RUN]
2022-12-01 02:24:25 [42mnormalization[0m > 4 of 6 START incremental model APP_mydb.mytable_a_SCD................................................................... [RUN]
2022-12-01 02:24:35 [42mnormalization[0m > 4 of 6 OK created incremental model APP_mydb.mytable_a_SCD.............................................................. [[32mSUCCESS 1[0m in 10.35s]
2022-12-01 02:24:35 [42mnormalization[0m > 5 of 6 START incremental model APP_mydb.mytable_a....................................................................... [RUN]
2022-12-01 02:24:40 [42mnormalization[0m > 5 of 6 OK created incremental model APP_mydb.mytable_a.................................................................. [[32mSUCCESS 1[0m in 4.70s]
2022-12-01 02:24:43 [42mnormalization[0m > 3 of 6 OK created incremental model APP_mydb.mytable_b_SCD............................................................. [[32mSUCCESS 1[0m in 18.11s]
2022-12-01 02:24:43 [42mnormalization[0m > 6 of 6 START incremental model APP_mydb.mytable_b...................................................................... [RUN]
2022-12-01 02:24:51 [42mnormalization[0m > 6 of 6 OK created incremental model APP_mydb.mytable_b................................................................. [[32mSUCCESS 1[0m in 8.34s]
2022-12-01 02:24:51 [42mnormalization[0m > Finished running 2 view models, 4 incremental models in 32.11s.
2022-12-01 02:24:52 [42mnormalization[0m > [32mCompleted successfully[0m
2022-12-01 02:24:52 [42mnormalization[0m > Done. PASS=6 WARN=0 ERROR=0 SKIP=0 TOTAL=6
2022-12-01 02:24:53 [32mINFO[m i.a.w.g.DefaultNormalizationWorker(run):93 - Normalization executed in 46 seconds.
2022-12-01 02:24:53 [32mINFO[m i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@269ace1f[startTime=1669861447606,endTime=1669861493853,failures=[]]
2022-12-01 02:24:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling...
2022-12-01 02:24:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2022-12-01 02:24:53 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2022-12-01 02:24:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION -----
2022-12-01 02:24:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -