2023-02-08 09:02:50 WARN c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-02-08 09:02:50 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/20/0/logs.log 2023-02-08 09:02:50 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.27 2023-02-08 09:02:50 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2023-02-08 09:02:50 INFO i.a.c.EnvConfigs(getEnvOrDefault):1173 - Using default value for environment variable METRIC_CLIENT: '' 2023-02-08 09:02:50 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable FIELD_SELECTION_WORKSPACES: '' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable APPLY_FIELD_SELECTION: 'false' 2023-02-08 09:02:50 INFO i.a.w.g.DefaultReplicationWorker(run):148 - start sync worker. job id: 20 attempt id: 0 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:02:50 INFO i.a.w.g.DefaultReplicationWorker(run):163 - configured sync modes: {null.GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL=full_refresh - overwrite} 2023-02-08 09:02:50 INFO i.a.w.i.DefaultAirbyteDestination(start):78 - Running destination... 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable APPLY_FIELD_SELECTION: 'false' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable FIELD_SELECTION_WORKSPACES: '' 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-mysql:0.1.20 exists... 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-mysql:0.1.20 was found locally. 2023-02-08 09:02:50 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-mysql-write-20-0-iovnn with resources io.airbyte.config.ResourceRequirements@23c79263[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-02-08 09:02:50 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/20/0 --log-driver none --name destination-mysql-write-20-0-iovnn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.27 -e WORKER_JOB_ID=20 airbyte/destination-mysql:0.1.20 write --config destination_config.json --catalog destination_catalog.json 2023-02-08 09:02:50 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0 2023-02-08 09:02:50 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):100 - Reading messages from protocol version 0.2.0 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable APPLY_FIELD_SELECTION: 'false' 2023-02-08 09:02:50 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable FIELD_SELECTION_WORKSPACES: '' 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-amazon-seller-partner:0.2.31 exists... 2023-02-08 09:02:50 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-amazon-seller-partner:0.2.31 was found locally. 2023-02-08 09:02:50 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-amazon-seller-partner-read-20-0-tldpd with resources io.airbyte.config.ResourceRequirements@7bdc27aa[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-02-08 09:02:50 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/20/0 --log-driver none --name source-amazon-seller-partner-read-20-0-tldpd --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.31 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.27 -e WORKER_JOB_ID=20 airbyte/source-amazon-seller-partner:0.2.31 read --config source_config.json --catalog source_catalog.json --state input_state.json 2023-02-08 09:02:50 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):100 - Reading messages from protocol version 0.2.0 2023-02-08 09:02:50 INFO i.a.w.g.DefaultReplicationWorker(replicate):243 - Waiting for source and destination threads to complete. 2023-02-08 09:02:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):271 - Destination output thread started. 2023-02-08 09:02:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):333 - Replication thread started. 2023-02-08 09:02:51 destination > SLF4J: Class path contains multiple SLF4J bindings. 2023-02-08 09:02:51 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-08 09:02:51 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-08 09:02:51 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2023-02-08 09:02:51 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2023-02-08 09:02:51 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2023-02-08 09:02:51 source > Starting syncing SourceAmazonSellerPartner 2023-02-08 09:02:51 destination > 2023-02-08 09:02:51 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 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 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 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 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 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 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 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 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2023-02-08 09:02:52 source > Syncing stream: GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, namespace=null, outputSchemaName=msz_prod, tmpTableName=_airbyte_tmp_dad_get___y_last_update_general, outputTableName=_airbyte_raw_get_flat__y_last_update_general, syncMode=overwrite} 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 1 streams 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema: msz_prod, tmp table name: _airbyte_tmp_dad_get___y_last_update_general 2023-02-08 09:02:52 destination > 2023-02-08 09:02:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed. 2023-02-08 09:04:54 source > The report for stream 'GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL' was cancelled or there is no data to return 2023-02-08 09:04:54 source > Read 0 records from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL stream 2023-02-08 09:04:54 source > Finished syncing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:04:54 source > SourceAmazonSellerPartner runtimes: Syncing stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 0:02:01.862361 2023-02-08 09:04:54 source > Finished syncing SourceAmazonSellerPartner 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):390 - Total records read: 0 (0 bytes) 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(replicate):248 - One of source or destination thread complete. Waiting on the other. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):138 - No onDestinationCloseOperations required for this destination. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):163 - Finalizing tables in destination started for 1 streams 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema msz_prod, tmp table _airbyte_tmp_dad_get___y_last_update_general, final table _airbyte_raw_get_flat__y_last_update_general 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Executing finalization of tables. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Finalizing tables in destination completed. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):186 - Cleaning tmp tables in destination started for 1 streams 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema msz_prod, tmp table name: _airbyte_tmp_dad_get___y_last_update_general 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):195 - Cleaning tmp tables in destination completed. 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2023-02-08 09:04:54 destination > 2023-02-08 09:04:54 INFO i.a.i.d.m.MySQLDestination(main):138 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(replicate):250 - Source and destination threads complete. 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):550 - Source did not output any state messages 2023-02-08 09:04:54 WARN i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):558 - State capture: No new state, falling back on input state: io.airbyte.config.State@537a4edd[state={}] 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):481 - sync summary: { "status" : "completed", "recordsSynced" : 0, "bytesSynced" : 0, "startTime" : 1675846970836, "endTime" : 1675847094597, "totalStats" : { "bytesEmitted" : 0, "destinationStateMessagesEmitted" : 0, "destinationWriteEndTime" : 1675847094597, "destinationWriteStartTime" : 1675846970920, "meanSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBetweenStateMessageEmittedandCommitted" : 0, "meanSecondsBetweenStateMessageEmittedandCommitted" : 0, "recordsEmitted" : 0, "recordsCommitted" : 0, "replicationEndTime" : 1675847094597, "replicationStartTime" : 1675846970836, "sourceReadEndTime" : 1675847094423, "sourceReadStartTime" : 1675846970874, "sourceStateMessagesEmitted" : 0 }, "streamStats" : [ ] } 2023-02-08 09:04:54 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):482 - failures: [ ] 2023-02-08 09:04:54 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling... 2023-02-08 09:04:54 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):207 - sync summary: io.airbyte.config.StandardSyncOutput@1ff9f624[standardSyncSummary=io.airbyte.config.StandardSyncSummary@71f7ea96[status=completed,recordsSynced=0,bytesSynced=0,startTime=1675846970836,endTime=1675847094597,totalStats=io.airbyte.config.SyncStats@e3a9b61[bytesEmitted=0,destinationStateMessagesEmitted=0,destinationWriteEndTime=1675847094597,destinationWriteStartTime=1675846970920,estimatedBytes=,estimatedRecords=,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,recordsEmitted=0,recordsCommitted=0,replicationEndTime=1675847094597,replicationStartTime=1675846970836,sourceReadEndTime=1675847094423,sourceReadStartTime=1675846970874,sourceStateMessagesEmitted=0,additionalProperties={}],streamStats=[]],normalizationSummary=,webhookOperationSummary=,state=io.airbyte.config.State@537a4edd[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@1d244166[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@4dbcdc30[stream=io.airbyte.protocol.models.AirbyteStream@3513c4b[name=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL,jsonSchema={"type":"object","title":"Flat File All Orders Data Reports (by last update)","$schema":"http://json-schema.org/draft-07/schema#","properties":{"sku":{"type":["null","string"]},"asin":{"type":["null","string"]},"currency":{"type":["null","string"]},"item-tax":{"type":["null","string"]},"quantity":{"type":["null","string"]},"ship-city":{"type":["null","string"]},"item-price":{"type":["null","string"]},"ship-state":{"type":["null","string"]},"item-status":{"type":["null","string"]},"order-status":{"type":["null","string"]},"product-name":{"type":["null","string"]},"ship-country":{"type":["null","string"]},"shipping-tax":{"type":["null","string"]},"gift-wrap-tax":{"type":["null","string"]},"order-channel":{"type":["null","string"]},"promotion-ids":{"type":["null","string"]},"purchase-date":{"type":["null","string"],"format":"date-time"},"sales-channel":{"type":["null","string"]},"shipping-price":{"type":["null","string"]},"amazon-order-id":{"type":"string"},"gift-wrap-price":{"type":["null","string"]},"ship-postal-code":{"type":["null","string"]},"is-business-order":{"type":["null","string"]},"last-updated-date":{"type":"string","format":"date-time"},"merchant-order-id":{"type":["null","string"]},"price-designation":{"type":["null","string"]},"ship-service-level":{"type":["null","string"]},"fulfillment-channel":{"type":["null","string"]},"purchase-order-number":{"type":["null","string"]},"item-promotion-discount":{"type":["null","string"]},"ship-promotion-discount":{"type":["null","string"]}},"description":"Flat File All Orders Data by Last Update Date General Reports"},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[last-updated-date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[last-updated-date],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2023-02-08 09:04:54 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):212 - Sync summary length: 3170 2023-02-08 09:04:54 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:04:54 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state 2023-02-08 09:04:54 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):71 - Using default value for environment variable NEED_STATE_VALIDATION: 'true' 2023-02-08 09:04:54 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state 2023-02-08 09:04:54 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get normalization statuses 2023-02-08 09:04:54 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/20/0/logs.log 2023-02-08 09:04:54 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.27 2023-02-08 09:04:54 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION ----- 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:04:54 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):125 - Running with normalization version: airbyte/normalization-mysql:0.2.25 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-mysql:0.2.25 exists... 2023-02-08 09:04:54 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-mysql:0.2.25 was found locally. 2023-02-08 09:04:54 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = normalization-mysql-normalize-20-0-aghkc with resources io.airbyte.config.ResourceRequirements@6c54f034[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-02-08 09:04:54 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/20/0/normalize --log-driver none --name normalization-mysql-normalize-20-0-aghkc --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.40.27 airbyte/normalization-mysql:0.2.25 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json 2023-02-08 09:04:54 normalization > Running: transform-config --config destination_config.json --integration-type mysql --out /data/20/0/normalize 2023-02-08 09:04:55 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/20/0/normalize') 2023-02-08 09:04:55 normalization > transform_mysql 2023-02-08 09:04:55 normalization > Running: transform-catalog --integration-type mysql --profile-config-dir /data/20/0/normalize --catalog destination_catalog.json --out /data/20/0/normalize/models/generated/ --json-column _airbyte_data 2023-02-08 09:04:55 normalization > Processing destination_catalog.json... 2023-02-08 09:04:55 normalization > Truncating _airbyte_raw_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#65) to _airbyte_raw_GET_FLAT_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating _airbyte_raw_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#65) to _airbyte_raw_GET_FLAT_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab1 (#48) to get_flat_file_all_ord_st_update_general_ab1 (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab1 (#48) to get_flat_file_all_ord_st_update_general_ab1 (#44) 2023-02-08 09:04:55 normalization > Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab1.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab2 (#48) to get_flat_file_all_ord_st_update_general_ab2 (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab2 (#48) to get_flat_file_all_ord_st_update_general_ab2 (#44) 2023-02-08 09:04:55 normalization > Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab2.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating _airbyte_get_flat_file_all_ord__y_last_update_general_hashid (#60) to _airbyte_get_flat_fil_update_general_hashid (#44) 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab3 (#48) to get_flat_file_all_ord_st_update_general_ab3 (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab3 (#48) to get_flat_file_all_ord_st_update_general_ab3 (#44) 2023-02-08 09:04:55 normalization > Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab3.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating _airbyte_get_flat_file_all_ord__y_last_update_general_hashid (#60) to _airbyte_get_flat_fil_update_general_hashid (#44) 2023-02-08 09:04:55 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44) 2023-02-08 09:04:55 normalization > Truncating get_flat_file_all_ord__y_last_update_general_scd (#48) to get_flat_file_all_ord_st_update_general_scd (#44) 2023-02-08 09:04:55 normalization > Adding drop table hook for get_flat_file_all_ord_1st_update_general_scd to get_flat_file_all_ord__y_last_update_general 2023-02-08 09:04:55 normalization > Generating airbyte_tables/msz_prod/get_flat_file_all_ord__y_last_update_general.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 2023-02-08 09:04:55 normalization > detected no config file for ssh, assuming ssh is off. 2023-02-08 09:04:57 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2023-02-08 09:04:57 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2023-02-08 09:04:57 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2023-02-08 09:04:57 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2023-02-08 09:04:57 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2023-02-08 09:05:00 normalization > Running with dbt=1.0.0 2023-02-08 09:05:00 normalization > Partial parse save file not found. Starting full parse. 2023-02-08 09:05:01 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. There are 2 unused configuration paths: - models.airbyte_utils.generated.airbyte_incremental - models.airbyte_utils.generated.airbyte_views 2023-02-08 09:05:01 normalization > Found 4 models, 0 tests, 0 snapshots, 0 analyses, 584 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2023-02-08 09:05:01 normalization > Concurrency: 1 threads (target='prod') 2023-02-08 09:05:01 normalization > 1 of 1 START table model msz_prod.get_flat_file_all_ord__y_last_update_general.......................................... [RUN] 2023-02-08 09:05:01 normalization > 1 of 1 OK created table model msz_prod.get_flat_file_all_ord__y_last_update_general..................................... [SUCCESS 0 in 0.14s] 2023-02-08 09:05:01 normalization > Finished running 1 table model in 0.39s. 2023-02-08 09:05:01 normalization > Completed successfully 2023-02-08 09:05:01 normalization > Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1 2023-02-08 09:05:02 INFO i.a.w.n.DefaultNormalizationRunner(close):189 - Terminating normalization process... 2023-02-08 09:05:02 INFO i.a.w.n.DefaultNormalizationRunner(close):202 - Normalization process successfully terminated. 2023-02-08 09:05:02 INFO i.a.w.g.DefaultNormalizationWorker(run):94 - Normalization executed in 7 seconds for job 20. 2023-02-08 09:05:02 INFO i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@50d265b4[startTime=1675847094765,endTime=1675847102138,failures=[]] 2023-02-08 09:05:02 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling... 2023-02-08 09:05:02 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2023-02-08 09:05:02 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-02-08 09:05:02 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION ----- 2023-02-08 09:05:02 INFO i.a.c.i.LineGobbler(voidCall):114 -