2022-04-11 16:08:18 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.15-alpha
2022-04-11 16:08:18 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/28779/0/logs.log
2022-04-11 16:08:18 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.15-alpha
2022-04-11 16:08:18 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-04-11 16:08:18 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-04-11 16:08:18 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-04-11 16:08:18 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-04-11 16:08:18 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 28779 attempt id: 0
2022-04-11 16:08:18 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL=incremental - append_dedup}
2022-04-11 16:08:18 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-11 16:08:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.3.14 exists...
2022-04-11 16:08:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.3.14 was found locally.
2022-04-11 16:08:18 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/28779/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-snowflake:0.3.14 write --config destination_config.json --catalog destination_catalog.json
2022-04-11 16:08:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-amazon-seller-partner:0.2.14 exists...
2022-04-11 16:08:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-amazon-seller-partner:0.2.14 was found locally.
2022-04-11 16:08:18 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/28779/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-amazon-seller-partner:0.2.14 read --config source_config.json --catalog source_catalog.json
2022-04-11 16:08:18 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):307 - Destination output thread started.
2022-04-11 16:08:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):268 - Replication thread started.
2022-04-11 16:08:18 INFO i.a.w.DefaultReplicationWorker(run):147 - Waiting for source and destination threads to complete.
2022-04-11 16:08:19 source > Starting syncing SourceAmazonSellerPartner
2022-04-11 16:08:19 destination > 2022-04-11 16:08:19 INFO i.a.i.d.s.SnowflakeDestination(main):81 - {} - starting destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 16:08:19 destination > 2022-04-11 16:08:19 INFO i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 16:08:19 destination > 2022-04-11 16:08:19 INFO i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-11 16:08:19 destination > 2022-04-11 16:08:19 INFO i.a.i.b.IntegrationRunner(run):100 - {} - Command: WRITE
2022-04-11 16:08:19 destination > 2022-04-11 16:08:19 INFO i.a.i.b.IntegrationRunner(run):101 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 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
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 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
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 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
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 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
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):83 - {} - Using destination type: INSERT
2022-04-11 16:08:20 source > Syncing stream: GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):116 - {} - Write config: WriteConfig{streamName=ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, namespace=null, outputSchemaName=Maplemonk, tmpTableName=_airbyte_tmp_otd_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, outputTableName=_airbyte_raw_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, syncMode=append_dedup}
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):143 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):139 - {} - Preparing tmp tables in destination started for 1 streams
2022-04-11 16:08:20 destination > 2022-04-11 16:08:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):143 - {} - Preparing tmp table in destination started for stream ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema: Maplemonk, tmp table name: _airbyte_tmp_otd_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:08:23 destination > 2022-04-11 16:08:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tables in destination completed.
2022-04-11 16:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 1000
2022-04-11 16:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 2000
2022-04-11 16:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 3000
2022-04-11 16:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 4000
2022-04-11 16:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 5000
2022-04-11 16:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 6000
2022-04-11 16:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 7000
2022-04-11 16:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 8000
2022-04-11 16:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 9000
2022-04-11 16:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 10000
2022-04-11 16:19:04 destination > 2022-04-11 16:19:04 INFO i.a.i.d.s.SnowflakeSqlOperations(insertRecordsInternal):57 - {} - actual size of batch: 10000
2022-04-11 16:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 11000
2022-04-11 16:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 12000
2022-04-11 16:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 13000
2022-04-11 16:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 14000
2022-04-11 16:19:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 15000
2022-04-11 16:19:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 16000
2022-04-11 16:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 17000
2022-04-11 16:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 18000
2022-04-11 16:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 19000
2022-04-11 16:19:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 20000
2022-04-11 16:19:13 destination > 2022-04-11 16:19:13 INFO i.a.i.d.s.SnowflakeSqlOperations(insertRecordsInternal):57 - {} - actual size of batch: 10000
2022-04-11 16:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 21000
2022-04-11 16:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 22000
2022-04-11 16:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):281 - Records read: 23000
2022-04-11 16:19:21 source > Encountered an exception while reading stream SourceAmazonSellerPartner
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    internal_config=internal_config,
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 185, in _read_incremental
    for record_counter, record_data in enumerate(records, start=1):
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 334, in read_records
    yield from self.parse_response(response)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 290, in parse_response
    yield from document_records
  File "/usr/local/lib/python3.7/csv.py", line 112, in __next__
    row = next(self.reader)
_csv.Error: field larger than field limit (131072)
2022-04-11 16:19:21 source > Finished syncing SourceAmazonSellerPartner
2022-04-11 16:19:21 source > SourceAmazonSellerPartner runtimes:

2022-04-11 16:19:21 source > field larger than field limit (131072)
Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 127, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 118, in run
    for message in generator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read
    raise e
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    internal_config=internal_config,
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 185, in _read_incremental
    for record_counter, record_data in enumerate(records, start=1):
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 334, in read_records
    yield from self.parse_response(response)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 290, in parse_response
    yield from document_records
  File "/usr/local/lib/python3.7/csv.py", line 112, in __next__
    row = next(self.reader)
_csv.Error: field larger than field limit (131072)
2022-04-11 16:19:22 destination > 2022-04-11 16:19:22 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2022-04-11 16:19:22 destination > 2022-04-11 16:19:22 INFO i.a.i.d.b.BufferedStreamConsumer(close):212 - {} - executing on success close procedure.
2022-04-11 16:19:22 destination > 2022-04-11 16:19:22 INFO i.a.i.d.s.SnowflakeSqlOperations(insertRecordsInternal):57 - {} - actual size of batch: 3653
2022-04-11 16:19:23 destination > 2022-04-11 16:19:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):176 - {} - Finalizing tables in destination started for 1 streams
2022-04-11 16:19:23 destination > 2022-04-11 16:19:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - {} - Finalizing stream ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema Maplemonk, tmp table _airbyte_tmp_otd_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, final table _airbyte_raw_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:24 destination > 2022-04-11 16:19:24 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):194 - {} - Executing finalization of tables.
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):196 - {} - Finalizing tables in destination completed.
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):199 - {} - Cleaning tmp tables in destination started for 1 streams
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):203 - {} - Cleaning tmp table in destination started for stream ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema Maplemonk, tmp table name: _airbyte_tmp_otd_ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):208 - {} - Cleaning tmp tables in destination completed.
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.b.IntegrationRunner(run):153 - {} - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 16:19:26 destination > 2022-04-11 16:19:26 INFO i.a.i.d.s.SnowflakeDestination(main):83 - {} - completed destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 16:19:27 ERROR i.a.w.DefaultReplicationWorker(run):158 - Sync worker failed.
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:151) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: 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:136) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-11 16:19:27 INFO i.a.w.DefaultReplicationWorker(run):217 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6952b7b4[status=failed,recordsSynced=23653,bytesSynced=23374894,startTime=1649693298297,endTime=1649693967631,totalStats=io.airbyte.config.SyncStats@22cbbb78[recordsEmitted=23653,bytesEmitted=23374894,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@197388bd[streamName=ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL,stats=io.airbyte.config.SyncStats@4d9eeb37[recordsEmitted=23653,bytesEmitted=23374894,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-11 16:19:27 INFO i.a.w.DefaultReplicationWorker(run):239 - Source did not output any state messages
2022-04-11 16:19:27 WARN i.a.w.DefaultReplicationWorker(run):250 - State capture: No state retained.
2022-04-11 16:19:27 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling...
2022-04-11 16:19:27 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):149 - sync summary: io.airbyte.config.StandardSyncOutput@10a9c094[standardSyncSummary=io.airbyte.config.StandardSyncSummary@15979bbb[status=failed,recordsSynced=23653,bytesSynced=23374894,startTime=1649693298297,endTime=1649693967631,totalStats=io.airbyte.config.SyncStats@22cbbb78[recordsEmitted=23653,bytesEmitted=23374894,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@197388bd[streamName=ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL,stats=io.airbyte.config.SyncStats@4d9eeb37[recordsEmitted=23653,bytesEmitted=23374894,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2e754d9f[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@39db9cb9[stream=io.airbyte.protocol.models.AirbyteStream@67285676[name=ASP_UK 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":{"name":"sku","type":"string","value":"sku"},"asin":{"name":"asin","type":"string","value":"asin"},"currency":{"name":"currency","type":"string","value":"currency"},"item-tax":{"name":"item-tax","type":"string","value":"item-tax"},"quantity":{"name":"quantity","type":"string","value":"quantity"},"ship-city":{"name":"ship-city","type":"string","value":"ship-city"},"item-price":{"name":"item-price","type":"string","value":"item-price"},"ship-state":{"name":"ship-state","type":"string","value":"ship-state"},"item-status":{"name":"item-status","type":"string","value":"item-status"},"order-status":{"name":"order-status","type":"string","value":"order-status"},"product-name":{"name":"product-name","type":"string","value":"product-name"},"ship-country":{"name":"ship-country","type":"string","value":"ship-country"},"shipping-tax":{"name":"shipping-tax","type":"string","value":"shipping-tax"},"gift-wrap-tax":{"name":"gift-wrap-tax","type":"string","value":"gift-wrap-tax"},"order-channel":{"name":"order-channel","type":"string","value":"order-channel"},"promotion-ids":{"name":"promotion-ids","type":"string","value":"promotion-ids"},"purchase-date":{"name":"purchase-date","type":"string","value":"purchase-date","format":"date-time"},"sales-channel":{"name":"sales-channel","type":"string","value":"sales-channel"},"shipping-price":{"name":"shipping-price","type":"string","value":"shipping-price"},"amazon-order-id":{"name":"amazon-order-id","type":"string","value":"amazon-order-id"},"gift-wrap-price":{"name":"gift-wrap-price","type":"string","value":"gift-wrap-price"},"ship-postal-code":{"name":"ship-postal-code","type":"string","value":"ship-postal-code"},"is-business-order":{"name":"is-business-order","type":"string","value":"is-business-order"},"last-updated-date":{"name":"last-updated-date","type":"string","value":"last-updated-date","format":"date-time"},"merchant-order-id":{"name":"merchant-order-id","type":"string","value":"merchant-order-id"},"price-designation":{"name":"price-designation","type":"string","value":"price-designation"},"ship-service-level":{"name":"ship-service-level","type":"string","value":"ship-service-level"},"fulfillment-channel":{"name":"fulfillment-channel","type":"string","value":"fulfillment-channel"},"purchase-order-number":{"name":"purchase-order-number","type":"string","value":"purchase-order-number"},"item-promotion-discount":{"name":"item-promotion-discount","type":"string","value":"item-promotion-discount"},"ship-promotion-discount":{"name":"ship-promotion-discount","type":"string","value":"ship-promotion-discount"}},"description":"Flat File All Orders Data by Last Update Date General Reports"},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[last-updated-date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[last-updated-date],destinationSyncMode=append_dedup,primaryKey=[[amazon-order-id], [asin]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@4e4b536b[failureOrigin=source,failureType=<null>,internalMessage=java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@4ad6f688[additionalProperties={attemptNumber=0, jobId=28779}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287)
	... 4 more
,timestamp=1649693962039]]]
2022-04-11 16:19:27 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating...
2022-04-11 16:19:27 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/28779/0/logs.log
2022-04-11 16:19:27 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.15-alpha
2022-04-11 16:19:27 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-04-11 16:19:27 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-04-11 16:19:27 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-04-11 16:19:27 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-04-11 16:19:27 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-11 16:19:27 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.65
2022-04-11 16:19:27 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.65 exists...
2022-04-11 16:19:27 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.65 was found locally.
2022-04-11 16:19:27 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/28779/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.65 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-04-11 16:19:28 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/28779/0/normalize
2022-04-11 16:19:28 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/28779/0/normalize')
2022-04-11 16:19:28 normalization > transform_snowflake
2022-04-11 16:19:28 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/28779/0/normalize --catalog destination_catalog.json --out /data/28779/0/normalize/models/generated/ --json-column _airbyte_data
2022-04-11 16:19:28 normalization > Processing destination_catalog.json...
2022-04-11 16:19:28 normalization >   Generating airbyte_ctes/MAPLEMONK/ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_AB1.sql from ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:28 normalization >   Generating airbyte_ctes/MAPLEMONK/ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_AB2.sql from ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:28 normalization >   Generating airbyte_views/MAPLEMONK/ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_STG.sql from ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:28 normalization >   Generating airbyte_incremental/scd/MAPLEMONK/ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_SCD.sql from ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:28 normalization >   Generating airbyte_incremental/MAPLEMONK/ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL.sql from ASP_UK GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2022-04-11 16:19:28 normalization > detected no config file for ssh, assuming ssh is off.
2022-04-11 16:19:31 normalization > Running with dbt=0.21.1
2022-04-11 16:19:32 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-04-11 16:19:34 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-04-11 16:19:34 normalization > There are 1 unused configuration paths:
2022-04-11 16:19:34 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-04-11 16:19:34 normalization > 
2022-04-11 16:19:34 normalization > Found 5 models, 0 tests, 0 snapshots, 0 analyses, 504 macros, 0 operations, 0 seed files, 1 source, 0 exposures
2022-04-11 16:19:34 normalization > 
2022-04-11 16:19:39 normalization > 16:19:39 | Concurrency: 5 threads (target='prod')
2022-04-11 16:19:39 normalization > 16:19:39 | 
2022-04-11 16:19:39 normalization > 16:19:39 | 1 of 3 START view model _AIRBYTE_MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_STG... [RUN]
2022-04-11 16:19:40 normalization > 16:19:40 | 1 of 3 OK created view model _AIRBYTE_MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_STG [SUCCESS 1 in 1.02s]
2022-04-11 16:19:40 normalization > 16:19:40 | 2 of 3 START incremental model MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_SCD..... [RUN]
2022-04-11 16:19:41 normalization > 16:19:41 + "VAHDAM_DB".MAPLEMONK."ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_SCD"._AIRBYTE_AB_ID does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-04-11 16:19:43 normalization > 16:19:43 | 2 of 3 OK created incremental model MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL_SCD [SUCCESS 1 in 3.13s]
2022-04-11 16:19:43 normalization > 16:19:43 | 3 of 3 START incremental model MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL......... [RUN]
2022-04-11 16:19:44 normalization > 16:19:44 + "VAHDAM_DB".MAPLEMONK."ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL"._AIRBYTE_AB_ID does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-04-11 16:19:46 normalization > 16:19:46 | 3 of 3 OK created incremental model MAPLEMONK.ASP_UK_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL.... [SUCCESS 1 in 3.15s]
2022-04-11 16:19:46 normalization > 16:19:46 | 
2022-04-11 16:19:46 normalization > 16:19:46 | Finished running 1 view model, 2 incremental models in 12.14s.
2022-04-11 16:19:46 normalization > 
2022-04-11 16:19:46 normalization > Completed successfully
2022-04-11 16:19:46 normalization > 
2022-04-11 16:19:46 normalization > Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3
2022-04-11 16:19:47 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 19 seconds.
2022-04-11 16:19:47 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling...
2022-04-11 16:19:47 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating...