2021-09-12 03:37:40 INFO () WorkerRun(call):62 - Executing worker wrapper. Airbyte version: 0.29.17-alpha
2021-09-12 03:37:40 INFO () TemporalAttemptExecution(get):114 - Executing worker wrapper. Airbyte version: 0.29.17-alpha
2021-09-12 03:37:40 WARN () Databases(createPostgresDatabaseWithRetry):57 - Waiting for database to become available...
2021-09-12 03:37:40 INFO () JobsDatabaseInstance(lambda$static$2):45 - Testing if jobs database is ready...
2021-09-12 03:37:41 INFO () Databases(createPostgresDatabaseWithRetry):74 - Database available!
2021-09-12 03:37:41 WARN () JsonMetaSchema(newValidator):338 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:41 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 23 attempt id: 0
2021-09-12 03:37:41 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {myschema.TABLE_A=incremental - append_dedup, myschema.TABLE_B=incremental - append_dedup, myschema.TABLE_C=incremental - append_dedup, myschema.TABLE_D=incremental - append_dedup, myschema.TABLE_E=incremental - append_dedup, myschema.TABLE_F=incremental - append_dedup, myschema.TABLE_G=incremental - append_dedup, myschema.TABLE_L=incremental - append_dedup, myschema.TABLE_H=incremental - append_dedup, myschema.TABLE_I=incremental - append_dedup, myschema.TABLE_J=incremental - append_dedup, myschema.TABLE_K=incremental - append_dedup}
2021-09-12 03:37:41 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-09-12 03:37:41 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-snowflake:0.3.13 exists...
2021-09-12 03:37:41 INFO () LineGobbler(voidCall):85 - airbyte/destination-snowflake:0.3.13 was found locally.
2021-09-12 03:37:41 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/23/0 --network host --log-driver none airbyte/destination-snowflake:0.3.13 write --config destination_config.json --catalog destination_catalog.json
2021-09-12 03:37:41 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-mysql:0.4.4 exists...
2021-09-12 03:37:41 INFO () LineGobbler(voidCall):85 - airbyte/source-mysql:0.4.4 was found locally.
2021-09-12 03:37:41 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/23/0 --network host --log-driver none airbyte/source-mysql:0.4.4 read --config source_config.json --catalog source_catalog.json --state input_state.json
2021-09-12 03:37:41 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-09-12 03:37:41 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-09-12 03:37:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.d.s.SnowflakeDestination(main):81 - {} - starting destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.b.IntegrationRunner(run):100 - {} - Command: WRITE
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.b.IntegrationRunner(run):101 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):83 - {} - Using destination type: COPY_S3
2021-09-12 03:37:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:44 INFO i.a.i.s.m.MySqlSource(main):249 - {} - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.source.mysql.MySqlSource
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.b.IntegrationRunner(run):100 - {} - Command: READ
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO 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-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_D', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_E', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_H', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_F', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_L', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_C', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_A', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_I', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_J', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_G', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_K', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):127 - {} - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='TABLE_B', connectorName=MYNAMESPACE'}. Cursor Field: null Value: null
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_A with full ID bK_8y2VJzy_dCke6PyJqDYvKk86z_yF9ZR4OGR.5idmSy609TP3Afh8djL6rJ4y0JeJvD6SaZ1aEUdC1B_rQYKn_eFAXlNXCeZsUco.Cy1H9LVgmX3M0oLR7o8XrgK4r
2021-09-12 03:37:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:45 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_H with full ID 1L2it4YsmEz2oycSrVw11VVLXW1.6BoOCEjw4U8LOCIqaaJFDzOIS2UYT1.eUnXVHwnw7AsjCHnKSrdOUjhN9beLGYYQe8CH1HIvincARlE5YkJBAMpb_n8IkFKXC4F5
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_C with full ID Na4YHdmn4IcQ2yasyyDDaPj_8u.OsVlKjUp56nVC72CC.wHGqVxsJxxMJPAFvXfqyRpdz3DhKblqeFCds_I9uQETsVXHq1pS._w4uWcteTdywmmo3GEUo860ra_NfUK8
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_D with full ID Iwo_ns8Dio4chiel9PYOfUaW1r1NJ4mmmovHWTtHErRFvj2qRvb08.sOtV9rpez7A1ezR.OFSiCrEXAZC03rUUc79DuvCLf_GMYIHCozlOvpKU6x7D4hkve2J_DFYGNX
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_I with full ID Npob.WMb2qeiKxpIxcAMn_dcKp35VMKR6oBmKBv98P7ImkhbnzxSzTVs6zKiJ2CmeYcLWEim2JvVyYAgi_6ANRZXH2H8lJQzZsUN_DX2llLe.8aILr5wOq78bATVJ.UB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.s.m.MySqlCdcTargetPosition(targetPosition):81 - {} - Target File position : FileName: mysql-bin-changelog.163341, Position : 660620
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_J with full ID TqThUQFrr1E9DbQk6R1hsyboZckWvrfo2IGI2DQZDyI7lppSM8DtmeCFQV4vIitxGMlDOSgPMBH91Jn.ozK59_CTHeNWoBcnxefz1xGFV262ALyVk37MTroMmSj_c98a
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.AirbyteDebeziumHandler(getIncrementalIterators):92 - {} - using CDC: true
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_E with full ID k.EkLkcO8gM8obmoZ2RSHltxq.XDGOL.tyAbhJXM1bejvotMHYPfk7xB6Fuh.Utj7ZS292DxzDvrg6Om2r5.SgHSI4WaDicXpp.bUplbP35lX4WI_Aqavh_5Eb91L0KJ
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO o.a.k.c.c.AbstractConfig(logAll):354 - {} - EmbeddedConfig values:
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	access.control.allow.methods =
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	access.control.allow.origin =
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	admin.listeners = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	bootstrap.servers = [localhost:9092]
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	client.dns.lookup = use_all_dns_ips
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	config.providers = []
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	connector.client.config.override.policy = None
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	key.converter = class org.apache.kafka.connect.json.JsonConverter
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	listeners = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	metric.reporters = []
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	metrics.num.samples = 2
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	metrics.recording.level = INFO
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	metrics.sample.window.ms = 30000
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.flush.interval.ms = 1000
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.flush.timeout.ms = 5000
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.storage.file.filename = /tmp/cdc-state-offset10685163203474812059/offset.dat
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.storage.partitions = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.storage.replication.factor = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	offset.storage.topic =
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	plugin.path = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	response.http.headers.config =
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.advertised.host.name = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.advertised.listener = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.advertised.port = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.extension.classes = []
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.host.name = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	rest.port = 8083
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.cipher.suites = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.client.auth = none
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.endpoint.identification.algorithm = https
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.engine.factory.class = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.key.password = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.keymanager.algorithm = SunX509
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.keystore.location = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.keystore.password = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.keystore.type = JKS
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.protocol = TLSv1.3
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.provider = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.secure.random.implementation = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.trustmanager.algorithm = PKIX
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.truststore.location = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.truststore.password = null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	ssl.truststore.type = JKS
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	task.shutdown.graceful.timeout.ms = 5000
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	topic.creation.enable = true
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	topic.tracking.allow.reset = true
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	topic.tracking.enable = true
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2021-09-12 03:37:46 INFO () JsonSchemaValidator(test):76 - JSON schema validation failed.
errors: $: unknown found, object expected
2021-09-12 03:37:46 ERROR () DefaultAirbyteStreamFactory(lambda$create$1):83 - Validation failed: null
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_F with full ID T8hwGyWCoq.A6.OAK5DbfjkdtqpjJ5ANhudK.KlcgIfp1qoTEANOCDFhCijT.o_V2pcWdCm4khaJHugOj9S_mp8MdNsxmkFU8e1u6762ONQGeYzCzXI_jF.TItK3OYgY
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN 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-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.d.c.c.BaseSourceTask(start):100 - {} - Starting MySqlConnectorTask with configuration:
...
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Using configuration property "database.blacklist" is deprecated and will be removed in future versions. Please use "database.exclude.list" instead.
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead.
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 WARN i.d.c.Configuration(lambda$getFallbackStringProperty$34):2135 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead.
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_G with full ID 07ADmw0Om_ZTqHLtpus4MwHbZiogg1fzy.ZWL9K.NuaL_7ngkFsErV7BBW6D6roxEasUA.oeRHchmdzs4mAc_vbTRKsmQndTTnXveuUcSdQgovQY04aJtpTiHxrVUCgK
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.d.c.m.MySqlConnectorTask(start):82 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Found existing offset: {ts_sec=1631235864, file=mysql-bin-changelog.162732, pos=834769, row=1, server_id=733956844, event=2}
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_L with full ID X84ftcpJBraIYCVFEU_syoQm515sutVZ5B7afK8rr4GeYDHKJ3d3Lls0ZtV5woDG71dIgcjAZQz2k0c7wGGkXTs8NgYZNwD90aG47nBmtEDFBQIUYdyAuFZ9nk9fnGfF
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_K with full ID EmUh4k0y35wNyl4ejgOE3gR7zQcAYJP6yekszWpjs3FXPw.RafjAzRHn1sipk2LHIpa4gKu2DFI.DSzDDKZr6eBwPIOnmr6w78B7cHKtkCdDuMKCLhOvrWSE1PPu9uUz
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.j.c.s.S3StreamCopier(<init>):96 - {} - S3 upload part size: 10 MB
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_B with full ID 7qLDnh6Q8b8Tc3vWgbnF8PGxzYx5kI.yWZPelzR_D7eQBHhOw2r_QPocpRWEHWutPSePycgvCfiolw0_GfNhzdUSixkYVNuWDNgr82CKbPPzWvSZdt_CxCykHckst.RE
2021-09-12 03:37:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:46 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):143 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-09-12 03:37:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:47 INFO i.d.c.m.MySqlConnectorTask(isBinlogAvailable):546 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Step 0: Get all known binlogs from MySQL
2021-09-12 03:37:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:47 INFO i.d.c.m.MySqlConnectorTask(isBinlogAvailable):561 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Connector requires binlog file 'mysql-bin-changelog.162732', but MySQL only has mysql-bin-changelog.163051, mysql-bin-changelog.163052, mysql-bin-changelog.163053, mysql-bin-changelog.163054, mysql-bin-changelog.163055, mysql-bin-changelog.163056, mysql-bin-changelog.163057, mysql-bin-changelog.163058, mysql-bin-changelog.163059, mysql-bin-changelog.163060, mysql-bin-changelog.163061, mysql-bin-changelog.163062, mysql-bin-changelog.163063, mysql-bin-changelog.163064, mysql-bin-changelog.163065, mysql-bin-changelog.163066, mysql-bin-changelog.163067, mysql-bin-changelog.163068, mysql-bin-changelog.163069, mysql-bin-changelog.163070, mysql-bin-changelog.163071, mysql-bin-changelog.163072, mysql-bin-changelog.163073, mysql-bin-changelog.163074, mysql-bin-changelog.163075, mysql-bin-changelog.163076, mysql-bin-changelog.163077, mysql-bin-changelog.163078, mysql-bin-changelog.163079, mysql-bin-changelog.163080, mysql-bin-changelog.163081, mysql-bin-changelog.163082, mysql-bin-changelog.163083, mysql-bin-changelog.163084, mysql-bin-changelog.163085, mysql-bin-changelog.163086, mysql-bin-changelog.163087, mysql-bin-changelog.163088, mysql-bin-changelog.163089, mysql-bin-changelog.163090, mysql-bin-changelog.163091, mysql-bin-changelog.163092, mysql-bin-changelog.163093, mysql-bin-changelog.163094, mysql-bin-changelog.163095, mysql-bin-changelog.163096, mysql-bin-changelog.163097, mysql-bin-changelog.163098, mysql-bin-changelog.163099, mysql-bin-changelog.163100, mysql-bin-changelog.163101, mysql-bin-changelog.163102, mysql-bin-changelog.163103, mysql-bin-changelog.163104, mysql-bin-changelog.163105, mysql-bin-changelog.163106, mysql-bin-changelog.163107, mysql-bin-changelog.163108, mysql-bin-changelog.163109, mysql-bin-changelog.163110, mysql-bin-changelog.163111, mysql-bin-changelog.163112, mysql-bin-changelog.163113, mysql-bin-changelog.163114, mysql-bin-changelog.163115, mysql-bin-changelog.163116, mysql-bin-changelog.163117, mysql-bin-changelog.163118, mysql-bin-changelog.163119, mysql-bin-changelog.163120, mysql-bin-changelog.163121, mysql-bin-changelog.163122, mysql-bin-changelog.163123, mysql-bin-changelog.163124, mysql-bin-changelog.163125, mysql-bin-changelog.163126, mysql-bin-changelog.163127, mysql-bin-changelog.163128, mysql-bin-changelog.163129, mysql-bin-changelog.163130, mysql-bin-changelog.163131, mysql-bin-changelog.163132, mysql-bin-changelog.163133, mysql-bin-changelog.163134, mysql-bin-changelog.163135, mysql-bin-changelog.163136, mysql-bin-changelog.163137, mysql-bin-changelog.163138, mysql-bin-changelog.163139, mysql-bin-changelog.163140, mysql-bin-changelog.163141, mysql-bin-changelog.163142, mysql-bin-changelog.163143, mysql-bin-changelog.163144, mysql-bin-changelog.163145, mysql-bin-changelog.163146, mysql-bin-changelog.163147, mysql-bin-changelog.163148, mysql-bin-changelog.163149, mysql-bin-changelog.163150, mysql-bin-changelog.163151, mysql-bin-changelog.163152, mysql-bin-changelog.163153, mysql-bin-changelog.163154, mysql-bin-changelog.163155, mysql-bin-changelog.163156, mysql-bin-changelog.163157, mysql-bin-changelog.163158, mysql-bin-changelog.163159, mysql-bin-changelog.163160, mysql-bin-changelog.163161, mysql-bin-changelog.163162, mysql-bin-changelog.163163, mysql-bin-changelog.163164, mysql-bin-changelog.163165, mysql-bin-changelog.163166, mysql-bin-changelog.163167, mysql-bin-changelog.163168, mysql-bin-changelog.163169, mysql-bin-changelog.163170, mysql-bin-changelog.163171, mysql-bin-changelog.163172, mysql-bin-changelog.163173, mysql-bin-changelog.163174, mysql-bin-changelog.163175, mysql-bin-changelog.163176, mysql-bin-changelog.163177, mysql-bin-changelog.163178, mysql-bin-changelog.163179, mysql-bin-changelog.163180, mysql-bin-changelog.163181, mysql-bin-changelog.163182, mysql-bin-changelog.163183, mysql-bin-changelog.163184, mysql-bin-changelog.163185, mysql-bin-changelog.163186, mysql-bin-changelog.163187, mysql-bin-changelog.163188, mysql-bin-changelog.163189, mysql-bin-changelog.163190, mysql-bin-changelog.163191, mysql-bin-changelog.163192, mysql-bin-changelog.163193, mysql-bin-changelog.163194, mysql-bin-changelog.163195, mysql-bin-changelog.163196, mysql-bin-changelog.163197, mysql-bin-changelog.163198, mysql-bin-changelog.163199, mysql-bin-changelog.163200, mysql-bin-changelog.163201, mysql-bin-changelog.163202, mysql-bin-changelog.163203, mysql-bin-changelog.163204, mysql-bin-changelog.163205, mysql-bin-changelog.163206, mysql-bin-changelog.163207, mysql-bin-changelog.163208, mysql-bin-changelog.163209, mysql-bin-changelog.163210, mysql-bin-changelog.163211, mysql-bin-changelog.163212, mysql-bin-changelog.163213, mysql-bin-changelog.163214, mysql-bin-changelog.163215, mysql-bin-changelog.163216, mysql-bin-changelog.163217, mysql-bin-changelog.163218, mysql-bin-changelog.163219, mysql-bin-changelog.163220, mysql-bin-changelog.163221, mysql-bin-changelog.163222, mysql-bin-changelog.163223, mysql-bin-changelog.163224, mysql-bin-changelog.163225, mysql-bin-changelog.163226, mysql-bin-changelog.163227, mysql-bin-changelog.163228, mysql-bin-changelog.163229, mysql-bin-changelog.163230, mysql-bin-changelog.163231, mysql-bin-changelog.163232, mysql-bin-changelog.163233, mysql-bin-changelog.163234, mysql-bin-changelog.163235, mysql-bin-changelog.163236, mysql-bin-changelog.163237, mysql-bin-changelog.163238, mysql-bin-changelog.163239, mysql-bin-changelog.163240, mysql-bin-changelog.163241, mysql-bin-changelog.163242, mysql-bin-changelog.163243, mysql-bin-changelog.163244, mysql-bin-changelog.163245, mysql-bin-changelog.163246, mysql-bin-changelog.163247, mysql-bin-changelog.163248, mysql-bin-changelog.163249, mysql-bin-changelog.163250, mysql-bin-changelog.163251, mysql-bin-changelog.163252, mysql-bin-changelog.163253, mysql-bin-changelog.163254, mysql-bin-changelog.163255, mysql-bin-changelog.163256, mysql-bin-changelog.163257, mysql-bin-changelog.163258, mysql-bin-changelog.163259, mysql-bin-changelog.163260, mysql-bin-changelog.163261, mysql-bin-changelog.163262, mysql-bin-changelog.163263, mysql-bin-changelog.163264, mysql-bin-changelog.163265, mysql-bin-changelog.163266, mysql-bin-changelog.163267, mysql-bin-changelog.163268, mysql-bin-changelog.163269, mysql-bin-changelog.163270, mysql-bin-changelog.163271, mysql-bin-changelog.163272, mysql-bin-changelog.163273, mysql-bin-changelog.163274, mysql-bin-changelog.163275, mysql-bin-changelog.163276, mysql-bin-changelog.163277, mysql-bin-changelog.163278, mysql-bin-changelog.163279, mysql-bin-changelog.163280, mysql-bin-changelog.163281, mysql-bin-changelog.163282, mysql-bin-changelog.163283, mysql-bin-changelog.163284, mysql-bin-changelog.163285, mysql-bin-changelog.163286, mysql-bin-changelog.163287, mysql-bin-changelog.163288, mysql-bin-changelog.163289, mysql-bin-changelog.163290, mysql-bin-changelog.163291, mysql-bin-changelog.163292, mysql-bin-changelog.163293, mysql-bin-changelog.163294, mysql-bin-changelog.163295, mysql-bin-changelog.163296, mysql-bin-changelog.163297, mysql-bin-changelog.163298, mysql-bin-changelog.163299, mysql-bin-changelog.163300, mysql-bin-changelog.163301, mysql-bin-changelog.163302, mysql-bin-changelog.163303, mysql-bin-changelog.163304, mysql-bin-changelog.163305, mysql-bin-changelog.163306, mysql-bin-changelog.163307, mysql-bin-changelog.163308, mysql-bin-changelog.163309, mysql-bin-changelog.163310, mysql-bin-changelog.163311, mysql-bin-changelog.163312, mysql-bin-changelog.163313, mysql-bin-changelog.163314, mysql-bin-changelog.163315, mysql-bin-changelog.163316, mysql-bin-changelog.163317, mysql-bin-changelog.163318, mysql-bin-changelog.163319, mysql-bin-changelog.163320, mysql-bin-changelog.163321, mysql-bin-changelog.163322, mysql-bin-changelog.163323, mysql-bin-changelog.163324, mysql-bin-changelog.163325, mysql-bin-changelog.163326, mysql-bin-changelog.163327, mysql-bin-changelog.163328, mysql-bin-changelog.163329, mysql-bin-changelog.163330, mysql-bin-changelog.163331, mysql-bin-changelog.163332, mysql-bin-changelog.163333, mysql-bin-changelog.163334, mysql-bin-changelog.163335, mysql-bin-changelog.163336, mysql-bin-changelog.163337, mysql-bin-changelog.163338, mysql-bin-changelog.163339, mysql-bin-changelog.163340, mysql-bin-changelog.163341
2021-09-12 03:37:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:47 INFO i.d.c.c.BaseSourceTask(stop):192 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Stopping down connector
2021-09-12 03:37:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:47 INFO i.d.c.m.MySqlConnectorTask(doStop):453 - {dbz.connectorContext=task, dbz.connectorName=MYCONNECTOR, dbz.connectorType=MySQL} - Stopping MySQL connector task
2021-09-12 03:37:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:37:47 INFO i.a.i.d.i.DebeziumRecordPublisher(lambda$start$1):105 - {} - Debezium engine shutdown.
2021-09-12 03:42:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:46 INFO i.a.i.d.i.DebeziumRecordIterator(computeNext):98 - {} - Closing cause next is returned as null
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - Exception in thread "main" java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: The connector is trying to read binlog starting at binlog file 'mysql-bin-changelog.162732', pos=834769, skipping 2 events plus 1 rows, but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.
2021-09-12 03:42:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:46 INFO i.d.e.EmbeddedEngine(stop):996 - {} - Stopping the embedded engine
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:152)
2021-09-12 03:42:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:46 INFO i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):200 - {} - Closing database connection pool.
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:99)
2021-09-12 03:42:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:46 INFO i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):202 - {} - Closed database connection pool.
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:52)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:42)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:83)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:83)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:139)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.source.mysql.MySqlSource.main(MySqlSource.java:250)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - Caused by: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: The connector is trying to read binlog starting at binlog file 'mysql-bin-changelog.162732', pos=834769, skipping 2 events plus 1 rows, but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.debezium.internals.DebeziumRecordPublisher.close(DebeziumRecordPublisher.java:137)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:35)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:149)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	... 20 more
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - Caused by: org.apache.kafka.connect.errors.ConnectException: The connector is trying to read binlog starting at binlog file 'mysql-bin-changelog.162732', pos=834769, skipping 2 events plus 1 rows, but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:132)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:106)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:758)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:171)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630)
2021-09-12 03:42:46 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.lang.Thread.run(Thread.java:832)
2021-09-12 03:42:48 INFO () DefaultReplicationWorker(run):141 - Source thread complete.
2021-09-12 03:42:48 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join.
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO i.a.i.d.b.BufferedStreamConsumer(close):212 - {} - executing on success close procedure.
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_B stream.
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_B with id 7qLDnh6Q8...kHckst.RE]: Completed
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_B stream uploaded.
2021-09-12 03:42:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:48 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:42:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:49 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_B, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_wld_TABLE_B.
2021-09-12 03:42:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:50 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_wld_TABLE_B in destination for stream: TABLE_B, schema: MY_SCHEMA, .
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_wld_TABLE_B in destination for stream TABLE_B complete.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_B in destination.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_wld_TABLE_B in destination prepared.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_wld_TABLE_B to dest table: _airbyte_raw_TABLE_B, schema: MY_SCHEMA, in destination.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_I stream.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_I with id Npob.WMb2...8bATVJ.UB]: Completed
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_I stream uploaded.
2021-09-12 03:42:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:53 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:42:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:54 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_I, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_bln_TABLE_I.
2021-09-12 03:42:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:54 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_bln_TABLE_I in destination for stream: TABLE_I, schema: MY_SCHEMA, .
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_bln_TABLE_I in destination for stream TABLE_I complete.
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_I in destination.
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_bln_TABLE_I in destination prepared.
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_bln_TABLE_I to dest table: _airbyte_raw_TABLE_I, schema: MY_SCHEMA, in destination.
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_L stream.
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_L with id X84ftcpJB...9nk9fnGfF]: Completed
2021-09-12 03:42:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_L stream uploaded.
2021-09-12 03:42:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:56 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:42:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:57 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_L, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_trp_TABLE_L.
2021-09-12 03:42:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:57 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_trp_TABLE_L in destination for stream: TABLE_L, schema: MY_SCHEMA, .
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_trp_TABLE_L in destination for stream TABLE_L complete.
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_L in destination.
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_trp_TABLE_L in destination prepared.
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_trp_TABLE_L to dest table: _airbyte_raw_TABLE_L, schema: MY_SCHEMA, in destination.
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_K stream.
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:42:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:42:59 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:00 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_K with id EmUh4k0y3...E1PPu9uUz]: Completed
2021-09-12 03:43:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:00 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_K stream uploaded.
2021-09-12 03:43:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:00 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:00 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_K, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_adq_TABLE_K.
2021-09-12 03:43:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:00 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_adq_TABLE_K in destination for stream: TABLE_K, schema: MY_SCHEMA, .
2021-09-12 03:43:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:02 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_adq_TABLE_K in destination for stream TABLE_K complete.
2021-09-12 03:43:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:02 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_K in destination.
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_adq_TABLE_K in destination prepared.
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_adq_TABLE_K to dest table: _airbyte_raw_TABLE_K, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_D stream.
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_D with id Iwo_ns8Di...2J_DFYGNX]: Completed
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_D stream uploaded.
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:03 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_D, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_vrg_TABLE_D.
2021-09-12 03:43:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:04 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_vrg_TABLE_D in destination for stream: TABLE_D, schema: MY_SCHEMA, .
2021-09-12 03:43:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:05 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_vrg_TABLE_D in destination for stream TABLE_D complete.
2021-09-12 03:43:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:05 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_D in destination.
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_vrg_TABLE_D in destination prepared.
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_vrg_TABLE_D to dest table: _airbyte_raw_TABLE_D, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_G stream.
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_G with id 07ADmw0Om...iHxrVUCgK]: Completed
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_G stream uploaded.
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:06 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_G, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_wxy_TABLE_G.
2021-09-12 03:43:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:07 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_wxy_TABLE_G in destination for stream: TABLE_G, schema: MY_SCHEMA, .
2021-09-12 03:43:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:08 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_wxy_TABLE_G in destination for stream TABLE_G complete.
2021-09-12 03:43:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:08 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_G in destination.
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_wxy_TABLE_G in destination prepared.
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_wxy_TABLE_G to dest table: _airbyte_raw_TABLE_G, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_J stream.
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_J with id TqThUQFrr...MmSj_c98a]: Completed
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_J stream uploaded.
2021-09-12 03:43:11 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:11 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:15 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:15 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_J, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_wyl_TABLE_J.
2021-09-12 03:43:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:18 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_wyl_TABLE_J in destination for stream: TABLE_J, schema: MY_SCHEMA, .
2021-09-12 03:43:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:19 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_wyl_TABLE_J in destination for stream TABLE_J complete.
2021-09-12 03:43:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:19 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_J in destination.
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_wyl_TABLE_J in destination prepared.
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_wyl_TABLE_J to dest table: _airbyte_raw_TABLE_J, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_H stream.
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_H with id 1L2it4Ysm...IkFKXC4F5]: Completed
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_H stream uploaded.
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:20 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_H, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_cmd_TABLE_H.
2021-09-12 03:43:21 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:21 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_cmd_TABLE_H in destination for stream: TABLE_H, schema: MY_SCHEMA, .
2021-09-12 03:43:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:22 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_cmd_TABLE_H in destination for stream TABLE_H complete.
2021-09-12 03:43:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:22 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_H in destination.
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_cmd_TABLE_H in destination prepared.
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_cmd_TABLE_H to dest table: _airbyte_raw_TABLE_H, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_A stream.
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_A with id bK_8y2VJz...7o8XrgK4r]: Completed
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_A stream uploaded.
2021-09-12 03:43:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:23 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:24 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_A, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_nlp_TABLE_A.
2021-09-12 03:43:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:24 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_nlp_TABLE_A in destination for stream: TABLE_A, schema: MY_SCHEMA, .
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_nlp_TABLE_A in destination for stream TABLE_A complete.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_A in destination.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_nlp_TABLE_A in destination prepared.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_nlp_TABLE_A to dest table: _airbyte_raw_TABLE_A, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_F stream.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_F with id T8hwGyWCo...TItK3OYgY]: Completed
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_F stream uploaded.
2021-09-12 03:43:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:26 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:27 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_F, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_hxg_TABLE_F.
2021-09-12 03:43:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:27 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_hxg_TABLE_F in destination for stream: TABLE_F, schema: MY_SCHEMA, .
2021-09-12 03:43:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:29 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_hxg_TABLE_F in destination for stream TABLE_F complete.
2021-09-12 03:43:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:29 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_F in destination.
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_hxg_TABLE_F in destination prepared.
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_hxg_TABLE_F to dest table: _airbyte_raw_TABLE_F, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_E stream.
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_E with id k.EkLkcO8...5Eb91L0KJ]: Completed
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_E stream uploaded.
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:30 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_E, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_dkb_TABLE_E.
2021-09-12 03:43:31 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:31 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_dkb_TABLE_E in destination for stream: TABLE_E, schema: MY_SCHEMA, .
2021-09-12 03:43:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:32 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_dkb_TABLE_E in destination for stream TABLE_E complete.
2021-09-12 03:43:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:32 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_E in destination.
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_dkb_TABLE_E in destination prepared.
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_dkb_TABLE_E to dest table: _airbyte_raw_TABLE_E, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):196 - {} - Uploading remaining data for TABLE_C stream.
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to MY-BUCKET/d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_C with id Na4YHdmn4...0ra_NfUK8]: Completed
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):200 - {} - All data for TABLE_C stream uploaded.
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):136 - {} - Creating schema in destination if it doesn't exist: MY_SCHEMA
2021-09-12 03:43:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:33 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):142 - {} - Preparing tmp table in destination for stream: TABLE_C, schema: MY_SCHEMA, tmp table name: _airbyte_tmp_xta_TABLE_C.
2021-09-12 03:43:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:34 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):148 - {} - Starting copy to tmp table: _airbyte_tmp_xta_TABLE_C in destination for stream: TABLE_C, schema: MY_SCHEMA, .
2021-09-12 03:43:35 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:35 INFO i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):150 - {} - Copy to tmp table _airbyte_tmp_xta_TABLE_C in destination for stream TABLE_C complete.
2021-09-12 03:43:35 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:35 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):156 - {} - Preparing table _airbyte_raw_TABLE_C in destination.
2021-09-12 03:43:36 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:36 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):158 - {} - Table _airbyte_tmp_xta_TABLE_C in destination prepared.
2021-09-12 03:43:36 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:36 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):165 - {} - Preparing to merge tmp table _airbyte_tmp_xta_TABLE_C to dest table: _airbyte_raw_TABLE_C, schema: MY_SCHEMA, in destination.
2021-09-12 03:43:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:40 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_B.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_B cleaned.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_wld_TABLE_B tmp table in destination.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_wld_TABLE_B tmp table in destination cleaned.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_I.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_I cleaned.
2021-09-12 03:43:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:41 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_bln_TABLE_I tmp table in destination.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_bln_TABLE_I tmp table in destination cleaned.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_L.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_L cleaned.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_trp_TABLE_L tmp table in destination.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_trp_TABLE_L tmp table in destination cleaned.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_K.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_K cleaned.
2021-09-12 03:43:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:42 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_adq_TABLE_K tmp table in destination.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_adq_TABLE_K tmp table in destination cleaned.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_D.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_D cleaned.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_vrg_TABLE_D tmp table in destination.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_vrg_TABLE_D tmp table in destination cleaned.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_G.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_G cleaned.
2021-09-12 03:43:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:43 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_wxy_TABLE_G tmp table in destination.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_wxy_TABLE_G tmp table in destination cleaned.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_J.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_J cleaned.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_wyl_TABLE_J tmp table in destination.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_wyl_TABLE_J tmp table in destination cleaned.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_H.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_H cleaned.
2021-09-12 03:43:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:44 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_cmd_TABLE_H tmp table in destination.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_cmd_TABLE_H tmp table in destination cleaned.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_A.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_A cleaned.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_nlp_TABLE_A tmp table in destination.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_nlp_TABLE_A tmp table in destination cleaned.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_F.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_F cleaned.
2021-09-12 03:43:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:45 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_hxg_TABLE_F tmp table in destination.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_hxg_TABLE_F tmp table in destination cleaned.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_E.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_E cleaned.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_dkb_TABLE_E tmp table in destination.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_dkb_TABLE_E tmp table in destination cleaned.
2021-09-12 03:43:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:46 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):177 - {} - Begin cleaning s3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_C.
2021-09-12 03:43:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:47 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):181 - {} - S3 staging file d3dc71b2-48c3-4055-930a-83a1b1037be9/MY_SCHEMA/TABLE_C cleaned.
2021-09-12 03:43:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:47 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):183 - {} - Begin cleaning _airbyte_tmp_xta_TABLE_C tmp table in destination.
2021-09-12 03:43:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:47 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):185 - {} - _airbyte_tmp_xta_TABLE_C tmp table in destination cleaned.
2021-09-12 03:43:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:47 INFO i.a.i.b.IntegrationRunner(run):153 - {} - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-09-12 03:43:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-09-12 03:43:47 INFO i.a.i.d.s.SnowflakeDestination(main):83 - {} - completed destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-09-12 03:43:50 INFO () DefaultReplicationWorker(run):144 - Destination thread complete.
2021-09-12 03:43:50 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:135) ~[io.airbyte-airbyte-workers-0.29.17-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:146) ~[io.airbyte-airbyte-workers-0.29.17-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.29.17-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$1(TemporalAttemptExecution.java:165) ~[io.airbyte-airbyte-workers-0.29.17-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-09-12 03:43:50 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@42ab55bc[status=failed,recordsSynced=0,bytesSynced=0,startTime=1631417861389,endTime=1631418230299]
2021-09-12 03:43:50 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-09-12 03:43:50 INFO () TemporalAttemptExecution(get):135 - Stopping cancellation check scheduling...
2021-09-12 03:43:50 INFO () TemporalAttemptExecution(get):114 - Executing worker wrapper. Airbyte version: 0.29.17-alpha
2021-09-12 03:43:50 WARN () Databases(createPostgresDatabaseWithRetry):57 - Waiting for database to become available...
2021-09-12 03:43:50 INFO () JobsDatabaseInstance(lambda$static$2):45 - Testing if jobs database is ready...
2021-09-12 03:43:50 INFO () Databases(createPostgresDatabaseWithRetry):74 - Database available!
2021-09-12 03:43:50 INFO () DefaultNormalizationWorker(run):63 - Running normalization.
2021-09-12 03:43:50 INFO () LineGobbler(voidCall):85 - Checking if airbyte/normalization:0.1.44 exists...
2021-09-12 03:43:50 INFO () LineGobbler(voidCall):85 - airbyte/normalization:0.1.44 was found locally.
2021-09-12 03:43:50 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/23/0/normalize --network host --log-driver none airbyte/normalization:0.1.44 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2021-09-12 03:43:53 INFO () LineGobbler(voidCall):85 - Running: transform-config --config destination_config.json --integration-type snowflake --out /data/23/0/normalize
2021-09-12 03:43:53 INFO () LineGobbler(voidCall):85 - Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/23/0/normalize')
2021-09-12 03:43:53 INFO () LineGobbler(voidCall):85 - transform_snowflake
2021-09-12 03:43:53 INFO () LineGobbler(voidCall):85 - Running: transform-catalog --integration-type snowflake --profile-config-dir /data/23/0/normalize --catalog destination_catalog.json --out /data/23/0/normalize/models/generated/ --json-column _airbyte_data
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 - Processing destination_catalog.json...
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_A_AB1.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_A_AB2.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_A_AB3.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_A_AB4.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_A_SCD.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_A.sql from TABLE_A
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_H_AB1.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_H_AB2.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_H_AB3.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_H_AB4.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_H_SCD.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_H.sql from TABLE_H
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_C_AB1.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_C_AB2.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_C_AB3.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_C_AB4.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_C_SCD.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_C.sql from TABLE_C
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_D_AB1.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_D_AB2.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_D_AB3.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_D_AB4.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_D_SCD.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_D.sql from TABLE_D
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_I_AB1.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_I_AB2.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_I_AB3.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_I_AB4.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_I_SCD.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_I.sql from TABLE_I
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_J_AB1.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_J_AB2.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_J_AB3.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_J_AB4.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_J_SCD.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_J.sql from TABLE_J
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_E_AB1.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_E_AB2.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_E_AB3.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_E_AB4.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_E_SCD.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_E.sql from TABLE_E
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_F_AB1.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_F_AB2.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_F_AB3.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_F_AB4.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_F_SCD.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_F.sql from TABLE_F
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_G_AB1.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_G_AB2.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_G_AB3.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_G_AB4.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_G_SCD.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_G.sql from TABLE_G
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_L_AB1.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_L_AB2.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_L_AB3.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_L_AB4.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_L_SCD.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_L.sql from TABLE_L
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_K_AB1.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_K_AB2.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_K_AB3.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_K_AB4.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_K_SCD.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_K.sql from TABLE_K
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_B_AB1.sql from TABLE_B
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_B_AB2.sql from TABLE_B
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_B_AB3.sql from TABLE_B
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/MY_SCHEMA/TABLE_B_AB4.sql from TABLE_B
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_B_SCD.sql from TABLE_B
2021-09-12 03:43:54 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/MY_SCHEMA/TABLE_B.sql from TABLE_B
2021-09-12 03:43:54 ERROR () LineGobbler(voidCall):85 - cat: /data/23/0/normalize/localsshport.json: No such file or directory
2021-09-12 03:43:55 INFO () LineGobbler(voidCall):85 - Running with dbt=0.19.0
2021-09-12 03:43:58 INFO () LineGobbler(voidCall):85 - [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2021-09-12 03:43:58 INFO () LineGobbler(voidCall):85 - There are 1 unused configuration paths:
2021-09-12 03:43:58 INFO () LineGobbler(voidCall):85 - - models.airbyte_utils.generated.airbyte_views
2021-09-12 03:43:58 INFO () LineGobbler(voidCall):85 -
2021-09-12 03:43:59 INFO () LineGobbler(voidCall):85 - Found 72 models, 0 tests, 0 snapshots, 0 analyses, 410 macros, 0 operations, 0 seed files, 12 sources, 0 exposures
2021-09-12 03:43:59 INFO () LineGobbler(voidCall):85 -
2021-09-12 03:44:02 INFO () LineGobbler(voidCall):85 - 03:44:02 | Concurrency: 32 threads (target='prod')
2021-09-12 03:44:02 INFO () LineGobbler(voidCall):85 - 03:44:02 |
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 1 of 24 START table model MY_SCHEMA.TABLE_C_SCD...................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 2 of 24 START table model MY_SCHEMA.TABLE_A_SCD............................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 3 of 24 START table model MY_SCHEMA.TABLE_H_SCD................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 4 of 24 START table model MY_SCHEMA.TABLE_D_SCD......................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 5 of 24 START table model MY_SCHEMA.TABLE_J_SCD....................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 6 of 24 START table model MY_SCHEMA.TABLE_E_SCD............................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 7 of 24 START table model MY_SCHEMA.TABLE_I_SCD................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 8 of 24 START table model MY_SCHEMA.TABLE_G_SCD............................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 9 of 24 START table model MY_SCHEMA.TABLE_F_SCD....................................................... [RUN]
2021-09-12 03:44:03 INFO () LineGobbler(voidCall):85 - 03:44:03 | 10 of 24 START table model MY_SCHEMA.TABLE_L_SCD................................................................. [RUN]
2021-09-12 03:44:04 INFO () LineGobbler(voidCall):85 - 03:44:04 | 11 of 24 START table model MY_SCHEMA.TABLE_K_SCD......................................................... [RUN]
2021-09-12 03:44:04 INFO () LineGobbler(voidCall):85 - 03:44:04 | 12 of 24 START table model MY_SCHEMA.TABLE_B_SCD........................................................... [RUN]
2021-09-12 03:44:08 INFO () LineGobbler(voidCall):85 - 03:44:08 | 8 of 24 OK created table model MY_SCHEMA.TABLE_G_SCD.......................................................... [SUCCESS 1 in 4.69s]
2021-09-12 03:44:08 INFO () LineGobbler(voidCall):85 - 03:44:08 | 13 of 24 START table model MY_SCHEMA.TABLE_G.................................................................. [RUN]
2021-09-12 03:44:08 INFO () LineGobbler(voidCall):85 - 03:44:08 | 6 of 24 OK created table model MY_SCHEMA.TABLE_E_SCD.......................................... [SUCCESS 1 in 5.10s]
2021-09-12 03:44:08 INFO () LineGobbler(voidCall):85 - 03:44:08 | 14 of 24 START table model MY_SCHEMA.TABLE_E.................................................. [RUN]
2021-09-12 03:44:09 INFO () LineGobbler(voidCall):85 - 03:44:09 | 4 of 24 OK created table model MY_SCHEMA.TABLE_D_SCD.................................... [SUCCESS 1 in 5.39s]
2021-09-12 03:44:09 INFO () LineGobbler(voidCall):85 - 03:44:09 | 15 of 24 START table model MY_SCHEMA.TABLE_D............................................ [RUN]
2021-09-12 03:44:11 INFO () LineGobbler(voidCall):85 - 03:44:11 | 14 of 24 OK created table model MY_SCHEMA.TABLE_E............................................. [SUCCESS 1 in 2.11s]
2021-09-12 03:44:11 INFO () LineGobbler(voidCall):85 - 03:44:11 | 15 of 24 OK created table model MY_SCHEMA.TABLE_D....................................... [SUCCESS 1 in 2.11s]
2021-09-12 03:44:11 INFO () LineGobbler(voidCall):85 - 03:44:11 | 13 of 24 OK created table model MY_SCHEMA.TABLE_G............................................................. [SUCCESS 1 in 2.78s]
2021-09-12 03:44:15 INFO () LineGobbler(voidCall):85 - 03:44:15 | 9 of 24 OK created table model MY_SCHEMA.TABLE_F_SCD.................................................. [SUCCESS 1 in 11.79s]
2021-09-12 03:44:15 INFO () LineGobbler(voidCall):85 - 03:44:15 | 16 of 24 START table model MY_SCHEMA.TABLE_F.......................................................... [RUN]
2021-09-12 03:44:19 INFO () LineGobbler(voidCall):85 - 03:44:19 | 16 of 24 OK created table model MY_SCHEMA.TABLE_F..................................................... [SUCCESS 1 in 3.32s]
2021-09-12 03:44:19 INFO () LineGobbler(voidCall):85 - 03:44:19 | 7 of 24 OK created table model MY_SCHEMA.TABLE_I_SCD.............................................. [SUCCESS 1 in 15.69s]
2021-09-12 03:44:19 INFO () LineGobbler(voidCall):85 - 03:44:19 | 17 of 24 START table model MY_SCHEMA.TABLE_I...................................................... [RUN]
2021-09-12 03:44:22 INFO () LineGobbler(voidCall):85 - 03:44:22 | 11 of 24 OK created table model MY_SCHEMA.TABLE_K_SCD.................................................... [SUCCESS 1 in 18.21s]
2021-09-12 03:44:22 INFO () LineGobbler(voidCall):85 - 03:44:22 | 18 of 24 START table model MY_SCHEMA.TABLE_K............................................................. [RUN]
2021-09-12 03:44:22 INFO () LineGobbler(voidCall):85 - 03:44:22 | 17 of 24 OK created table model MY_SCHEMA.TABLE_I................................................. [SUCCESS 1 in 3.32s]
2021-09-12 03:44:25 INFO () LineGobbler(voidCall):85 - 03:44:25 | 12 of 24 OK created table model MY_SCHEMA.TABLE_B_SCD...................................................... [SUCCESS 1 in 21.42s]
2021-09-12 03:44:25 INFO () LineGobbler(voidCall):85 - 03:44:25 | 19 of 24 START table model MY_SCHEMA.TABLE_B............................................................... [RUN]
2021-09-12 03:44:27 INFO () LineGobbler(voidCall):85 - 03:44:27 | 18 of 24 OK created table model MY_SCHEMA.TABLE_K........................................................ [SUCCESS 1 in 4.76s]
2021-09-12 03:44:31 INFO () LineGobbler(voidCall):85 - 03:44:31 | 19 of 24 OK created table model MY_SCHEMA.TABLE_B.......................................................... [SUCCESS 1 in 5.94s]
2021-09-12 03:44:34 INFO () LineGobbler(voidCall):85 - 03:44:34 | 3 of 24 OK created table model MY_SCHEMA.TABLE_H_SCD.............................................. [SUCCESS 1 in 31.07s]
2021-09-12 03:44:34 INFO () LineGobbler(voidCall):85 - 03:44:34 | 20 of 24 START table model MY_SCHEMA.TABLE_H...................................................... [RUN]
2021-09-12 03:44:35 INFO () LineGobbler(voidCall):85 - 03:44:35 | 5 of 24 OK created table model MY_SCHEMA.TABLE_J_SCD.................................................. [SUCCESS 1 in 31.59s]
2021-09-12 03:44:35 INFO () LineGobbler(voidCall):85 - 03:44:35 | 21 of 24 START table model MY_SCHEMA.TABLE_J.......................................................... [RUN]
2021-09-12 03:44:39 INFO () LineGobbler(voidCall):85 - 03:44:39 | 20 of 24 OK created table model MY_SCHEMA.TABLE_H................................................. [SUCCESS 1 in 4.36s]
2021-09-12 03:44:40 INFO () LineGobbler(voidCall):85 - 03:44:40 | 21 of 24 OK created table model MY_SCHEMA.TABLE_J..................................................... [SUCCESS 1 in 5.13s]
2021-09-12 03:44:47 INFO () LineGobbler(voidCall):85 - 03:44:47 | 1 of 24 OK created table model MY_SCHEMA.TABLE_C_SCD................................................. [SUCCESS 1 in 43.90s]
2021-09-12 03:44:47 INFO () LineGobbler(voidCall):85 - 03:44:47 | 22 of 24 START table model MY_SCHEMA.TABLE_C......................................................... [RUN]
2021-09-12 03:44:52 INFO () LineGobbler(voidCall):85 - 03:44:52 | 2 of 24 OK created table model MY_SCHEMA.TABLE_A_SCD.......................................................... [SUCCESS 1 in 48.41s]
2021-09-12 03:44:52 INFO () LineGobbler(voidCall):85 - 03:44:52 | 23 of 24 START table model MY_SCHEMA.TABLE_A.................................................................. [RUN]
2021-09-12 03:44:53 INFO () LineGobbler(voidCall):85 - 03:44:53 | 22 of 24 OK created table model MY_SCHEMA.TABLE_C.................................................... [SUCCESS 1 in 5.86s]
2021-09-12 03:44:57 INFO () LineGobbler(voidCall):85 - 03:44:57 | 23 of 24 OK created table model MY_SCHEMA.TABLE_A............................................................. [SUCCESS 1 in 5.53s]
2021-09-12 03:45:36 INFO () LineGobbler(voidCall):85 - 03:45:36 | 10 of 24 OK created table model MY_SCHEMA.TABLE_L_SCD............................................................ [SUCCESS 1 in 92.62s]
2021-09-12 03:45:36 INFO () LineGobbler(voidCall):85 - 03:45:36 | 24 of 24 START table model MY_SCHEMA.TABLE_L..................................................................... [RUN]
2021-09-12 03:45:47 INFO () LineGobbler(voidCall):85 - 03:45:47 | 24 of 24 OK created table model MY_SCHEMA.TABLE_L................................................................ [SUCCESS 1 in 10.50s]
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 - 03:45:48 |
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 - 03:45:48 | Finished running 24 table models in 109.22s.
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 -
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 - Completed successfully
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 -
2021-09-12 03:45:48 INFO () LineGobbler(voidCall):85 - Done. PASS=24 WARN=0 ERROR=0 SKIP=0 TOTAL=24
2021-09-12 03:45:50 INFO () DefaultNormalizationWorker(run):85 - Normalization executed in 2.
2021-09-12 03:45:50 INFO () TemporalAttemptExecution(get):135 - Stopping cancellation check scheduling...