2022-06-12 17:43:47 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.5-alpha
2022-06-12 17:43:47 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/204/2/logs.log
2022-06-12 17:43:47 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.36.5-alpha
2022-06-12 17:43:47 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 204 attempt id: 2
2022-06-12 17:43:47 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL=full_refresh - append}
2022-06-12 17:43:47 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-06-12 17:43:47 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.19 exists...
2022-06-12 17:43:47 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 204
2022-06-12 17:43:47 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/204/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.19 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.5-alpha -e WORKER_JOB_ID=204 airbyte/destination-postgres:0.3.19 write --config destination_config.json --catalog destination_catalog.json
2022-06-12 17:43:47 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.19 was found locally.
2022-06-12 17:43:48 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-amazon-seller-partner:0.2.20 exists...
2022-06-12 17:43:48 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-amazon-seller-partner:0.2.20 was found locally.
2022-06-12 17:43:48 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 204
2022-06-12 17:43:48 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/204/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.20 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.5-alpha -e WORKER_JOB_ID=204 airbyte/source-amazon-seller-partner:0.2.20 read --config source_config.json --catalog source_catalog.json
2022-06-12 17:43:48 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-06-12 17:43:48 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-06-12 17:43:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-06-12 17:43:50 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-06-12 17:43:50 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-12 17:43:50 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-12 17:43:50 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-12 17:43:50 source > Starting syncing SourceAmazonSellerPartner
2022-06-12 17:43:50 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-12 17:43:51 source > Syncing stream: GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL 
2022-06-12 17:43:52 destination > 2022-06-12 17:43:52 INFO i.a.i.d.p.PostgresDestination(main):89 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-06-12 17:43:53 destination > 2022-06-12 17:43:53 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-06-12 17:43:53 destination > 2022-06-12 17:43:53 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-06-12 17:43:53 destination > 2022-06-12 17:43:53 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-06-12 17:43:53 destination > 2022-06-12 17:43:53 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-06-12 17:43:53 destination > 2022-06-12 17:43:53 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-06-12 17:43:53 destination > 2022-06-12 17:43:53 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-06-12 17:43:53 destination > 2022-06-12 17:43:53 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-06-12 17:43:53 destination > 2022-06-12 17:43:53 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-06-12 17:43:54 destination > 2022-06-12 17:43:54 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-12 17:43:54 destination > 2022-06-12 17:43:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_men_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL, outputTableName=_airbyte_raw_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL, syncMode=append}
2022-06-12 17:43:54 destination > 2022-06-12 17:43:54 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-06-12 17:43:54 destination > 2022-06-12 17:43:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 1 streams
2022-06-12 17:43:54 destination > 2022-06-12 17:43:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL. schema: public, tmp table name: _airbyte_tmp_men_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:43:57 destination > 2022-06-12 17:43:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed.
2022-06-12 17:44:52 source > Encountered an exception while reading stream GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
Traceback (most recent call last):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 115, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 165, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 254, in _read_full_refresh
    for record in records:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 362, in read_records
    raise Exception(f"The report for stream '{self.name}' was aborted due to a fatal error")
Exception: The report for stream 'GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL' was aborted due to a fatal error
2022-06-12 17:44:52 source > Finished syncing GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:52 source > SourceAmazonSellerPartner runtimes:
Syncing stream GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL 0:01:01.158183
2022-06-12 17:44:52 source > The report for stream 'GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL' was aborted due to a fatal error
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.9/site-packages/airbyte_cdk/entrypoint.py", line 129, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 120, in run
    for message in generator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 129, in read
    raise e
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 115, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 165, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 254, in _read_full_refresh
    for record in records:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 362, in read_records
    raise Exception(f"The report for stream '{self.name}' was aborted due to a fatal error")
Exception: The report for stream 'GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL' was aborted due to a fatal error
2022-06-12 17:44:52 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.type: does not have a value in the enumeration [RECORD, STATE, LOG, SPEC, CONNECTION_STATUS, CATALOG]
2022-06-12 17:44:52 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: {"type":"TRACE","trace":{"type":"ERROR","emitted_at":1.655055892301071E12,"error":{"message":"Something went wrong in the connector. See the logs for more details.","internal_message":"The report for stream 'GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL' was aborted due to a fatal error","stack_trace":"Traceback (most recent call last):\n  File \"/airbyte/integration_code/main.py\", line 13, in <module>\n    launch(source, sys.argv[1:])\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 129, in launch\n    for message in source_entrypoint.run(parsed_args):\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 120, in run\n    for message in generator:\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 129, in read\n    raise e\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 115, in read\n    yield from self._read_stream(\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 165, in _read_stream\n    for record in record_iterator:\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 254, in _read_full_refresh\n    for record in records:\n  File \"/airbyte/integration_code/source_amazon_seller_partner/streams.py\", line 362, in read_records\n    raise Exception(f\"The report for stream '{self.name}' was aborted due to a fatal error\")\nException: The report for stream 'GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL' was aborted due to a fatal error\n","failure_type":"system_error"}}}
2022-06-12 17:44:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes)
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):136 - No onDestinationCloseOperations required for this destination.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):163 - Finalizing tables in destination started for 1 streams
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL. schema public, tmp table _airbyte_tmp_men_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL, final table _airbyte_raw_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Executing finalization of tables.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Finalizing tables in destination completed.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):186 - Cleaning tmp tables in destination started for 1 streams
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL. schema public, tmp table name: _airbyte_tmp_men_GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):195 - Cleaning tmp tables in destination completed.
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-06-12 17:44:52 destination > 2022-06-12 17:44:52 INFO i.a.i.d.p.PostgresDestination(main):91 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-06-12 17:44:53 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: 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:162) ~[io.airbyte-airbyte-workers-0.36.5-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.5-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.36.5-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.36.5-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.5-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.5-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.36.5-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.36.5-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-06-12 17:44:53 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@499b0e30[status=failed,recordsSynced=0,bytesSynced=0,startTime=1655055827870,endTime=1655055893037,totalStats=io.airbyte.config.SyncStats@3f18b4e2[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-06-12 17:44:53 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-06-12 17:44:53 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-06-12 17:44:53 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-12 17:44:53 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):155 - sync summary: io.airbyte.config.StandardSyncOutput@57d49945[standardSyncSummary=io.airbyte.config.StandardSyncSummary@12d61ddb[status=failed,recordsSynced=0,bytesSynced=0,startTime=1655055827870,endTime=1655055893037,totalStats=io.airbyte.config.SyncStats@3f18b4e2[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@28d1f8ee[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@238eae03[stream=io.airbyte.protocol.models.AirbyteStream@50631586[name=GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL,jsonSchema={"type":"object","title":"Amazon Fulfilled Data General","$schema":"http://json-schema.org/draft-07/schema#","properties":{"sku":{"type":["null","string"]},"carrier":{"type":["null","string"]},"currency":{"type":["null","string"]},"item-tax":{"type":["null","string"]},"bill-city":{"type":["null","string"]},"ship-city":{"type":["null","string"]},"bill-state":{"type":["null","string"]},"buyer-name":{"type":["null","string"]},"item-price":{"type":["null","string"]},"ship-state":{"type":["null","string"]},"buyer-email":{"type":["null","string"]},"shipment-id":{"type":["null","string"]},"bill-country":{"type":["null","string"]},"product-name":{"type":["null","string"]},"ship-country":{"type":["null","string"]},"shipping-tax":{"type":["null","string"]},"gift-wrap-tax":{"type":["null","string"]},"payments-date":{"type":["null","string"]},"purchase-date":{"type":["null","string"]},"sales-channel":{"type":["null","string"]},"shipment-date":{"type":["null","string"]},"bill-address-1":{"type":["null","string"]},"bill-address-2":{"type":["null","string"]},"bill-address-3":{"type":["null","string"]},"recipient-name":{"type":["null","string"]},"reporting-date":{"type":["null","string"]},"ship-address-1":{"type":["null","string"]},"ship-address-2":{"type":["null","string"]},"ship-address-3":{"type":["null","string"]},"shipping-price":{"type":["null","string"]},"amazon-order-id":{"type":["null","string"]},"gift-wrap-price":{"type":["null","string"]},"tracking-number":{"type":["null","string"]},"bill-postal-code":{"type":["null","string"]},"quantity-shipped":{"type":["null","string"]},"ship-postal-code":{"type":["null","string"]},"shipment-item-id":{"type":["null","string"]},"merchant-order-id":{"type":["null","string"]},"ship-phone-number":{"type":["null","string"]},"buyer-phone-number":{"type":["null","string"]},"ship-service-level":{"type":["null","string"]},"fulfillment-channel":{"type":["null","string"]},"amazon-order-item-id":{"type":["null","string"]},"fulfillment-center-id":{"type":["null","string"]},"estimated-arrival-date":{"type":["null","string"]},"merchant-order-item-id":{"type":["null","string"]},"item-promotion-discount":{"type":["null","string"]},"ship-promotion-discount":{"type":["null","string"]}},"description":"Amazon Fulfilled Data General Reports"},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@72f9e294[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@55c862ad[additionalProperties={attemptNumber=2, jobId=204}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: 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: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1655055892415]]]
2022-06-12 17:44:53 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-06-12 17:44:53 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/204/2/logs.log
2022-06-12 17:44:53 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.36.5-alpha
2022-06-12 17:44:53 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization.
2022-06-12 17:44:53 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.77
2022-06-12 17:44:53 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.77 exists...
2022-06-12 17:44:53 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.77 was found locally.
2022-06-12 17:44:53 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 204
2022-06-12 17:44:53 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/204/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.5-alpha airbyte/normalization:0.1.77 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json
2022-06-12 17:44:53 normalization > Running: transform-config --config destination_config.json --integration-type postgres --out /data/204/2/normalize
2022-06-12 17:44:53 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.POSTGRES: 'postgres'>, out='/data/204/2/normalize')
2022-06-12 17:44:53 normalization > transform_postgres
2022-06-12 17:44:53 normalization > Running: transform-catalog --integration-type postgres --profile-config-dir /data/204/2/normalize --catalog destination_catalog.json --out /data/204/2/normalize/models/generated/ --json-column _airbyte_data
2022-06-12 17:44:53 normalization > Processing destination_catalog.json...
2022-06-12 17:44:53 normalization >   Generating airbyte_ctes/public/get_amazon_fulfilled_shipments_data_general_ab1.sql from GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:53 normalization >   Generating airbyte_ctes/public/get_amazon_fulfilled_shipments_data_general_ab2.sql from GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:53 normalization > Truncating _airbyte_get_amazon_fulfilled_shipments_data_general_hashid (#59) to _airbyte_get_amazon__s_data_general_hashid (#43)
2022-06-12 17:44:53 normalization >   Generating airbyte_ctes/public/get_amazon_fulfilled_shipments_data_general_ab3.sql from GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:53 normalization > Truncating _airbyte_get_amazon_fulfilled_shipments_data_general_hashid (#59) to _airbyte_get_amazon__s_data_general_hashid (#43)
2022-06-12 17:44:53 normalization >   Generating airbyte_incremental/public/get_amazon_fulfilled_shipments_data_general.sql from GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL
2022-06-12 17:44:53 normalization > detected no config file for ssh, assuming ssh is off.
2022-06-12 17:44:56 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-06-12 17:44:56 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-06-12 17:44:56 normalization > 
2022-06-12 17:44:56 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-06-12 17:44:56 normalization > 
2022-06-12 17:44:59 normalization > 17:44:59  Running with dbt=1.0.0
2022-06-12 17:44:59 normalization > 17:44:59  Partial parse save file not found. Starting full parse.
2022-06-12 17:45:01 normalization > 17:45:01  [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-06-12 17:45:01 normalization > There are 2 unused configuration paths:
2022-06-12 17:45:01 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-06-12 17:45:01 normalization > - models.airbyte_utils.generated.airbyte_views
2022-06-12 17:45:01 normalization > 
2022-06-12 17:45:01 normalization > 17:45:01  Found 4 models, 0 tests, 0 snapshots, 0 analyses, 521 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-06-12 17:45:01 normalization > 17:45:01  
2022-06-12 17:45:04 normalization > 17:45:04  Concurrency: 8 threads (target='prod')
2022-06-12 17:45:04 normalization > 17:45:04  
2022-06-12 17:45:07 normalization > 17:45:07  1 of 1 START incremental model public.get_amazon_fulfilled_shipments_data_general....................................... [RUN]
2022-06-12 17:45:09 normalization > 17:45:09  1 of 1 OK created incremental model public.get_amazon_fulfilled_shipments_data_general.................................. [INSERT 0 2 in 1.89s]
2022-06-12 17:45:10 normalization > 17:45:10  
2022-06-12 17:45:10 normalization > 17:45:10  Finished running 1 incremental model in 8.81s.
2022-06-12 17:45:10 normalization > 17:45:10  
2022-06-12 17:45:10 normalization > 17:45:10  Completed successfully
2022-06-12 17:45:10 normalization > 17:45:10  
2022-06-12 17:45:10 normalization > 17:45:10  Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2022-06-12 17:45:10 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 17 seconds.
2022-06-12 17:45:10 INFO i.a.w.DefaultNormalizationWorker(run):77 - Normalization summary: io.airbyte.config.NormalizationSummary@ce9e485[startTime=1655055893120,endTime=1655055910363]
2022-06-12 17:45:10 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-12 17:45:10 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...