2022-04-04 18:54:18 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.64-alpha
2022-04-04 18:54:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/5132/0/logs.log
2022-04-04 18:54:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.64-alpha
2022-04-04 18:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 5132 attempt id: 0
2022-04-04 18:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.stage_powerschool_courses=full_refresh - append}
2022-04-04 18:54:18 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-04 18:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.28 exists...
2022-04-04 18:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 5132
2022-04-04 18:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.28 was found locally.
2022-04-04 18:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/5132/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-redshift:0.3.28 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=5132 airbyte/destination-redshift:0.3.28 write --config destination_config.json --catalog destination_catalog.json
2022-04-04 18:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-file:0.2.9 exists...
2022-04-04 18:54:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-file:0.2.9 was found locally.
2022-04-04 18:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 5132
2022-04-04 18:54:18 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/5132/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-file:0.2.9 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=5132 airbyte/source-file:0.2.9 read --config source_config.json --catalog source_catalog.json
2022-04-04 18:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-04 18:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-04 18:54:18 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-04 18:54:20 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-04 18:54:20 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 18:54:20 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 18:54:20 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-04 18:54:20 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-04 18:54:21 [44msource[0m > Reading powerschool_courses_ (sftp:///sftproot/dli-sftp/powerschool.courses.csv)...
2022-04-04 18:54:21 [44msource[0m > ignoring unsupported keyword arguments: ['connect_kwargs']
2022-04-04 18:54:22 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (124 KB)
2022-04-04 18:54:22 [43mdestination[0m > 2022-04-04 18:54:22 [32mINFO[m i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-04 18:54:23 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1837 (230 KB)
2022-04-04 18:54:23 [32mINFO[m i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [33mWARN[m 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-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [33mWARN[m 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-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3
2022-04-04 18:54:23 [43mdestination[0m > 2022-04-04 18:54:23 [32mINFO[m i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-04-04 18:54:25 [43mdestination[0m > 2022-04-04 18:54:25 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-04 18:54:25 [43mdestination[0m > 2022-04-04 18:54:25 [1;31mERROR[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):52 - Exception while accepting message
2022-04-04 18:54:25 [43mdestination[0m > java.lang.IllegalArgumentException: Message contained record from a stream that was not in the catalog. 
2022-04-04 18:54:25 [43mdestination[0m > catalog: {"streams":[{"stream":{"name":"sftp_stage_powerschool_courses","json_schema":{"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"ID":{"type":["number","null"]},"dcid":{"type":["number","null"]},"SchoolID":{"type":["number","null"]},"Add_to_GPA":{"type":["number","null"]},"Course_Name":{"type":["string","null"]},"Credit_Hours":{"type":["number","null"]},"Course_Number":{"type":["string","null"]}}},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"append","primary_key":[]}]} , 
2022-04-04 18:54:25 [43mdestination[0m > message: {"type":"RECORD","record":{"stream":"sftp_powerschool_courses_","data":{"Add_to_GPA":0,"dcid":1,"Course_Name":"INTRO CR ARTS","SchoolID":2681,"Credit_Hours":0.5,"Course_Number":"AR101","ID":1},"emitted_at":1649098462000}}
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.throwUnrecognizedStream(BufferedStreamConsumer.java:202) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:154) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) [io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:78) [io.airbyte.airbyte-integrations.connectors-destination-redshift-0.35.56-alpha.jar:?]
2022-04-04 18:54:25 [43mdestination[0m > 2022-04-04 18:54:25 [33mWARN[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: failed.
2022-04-04 18:54:25 [43mdestination[0m > 2022-04-04 18:54:25 [1;31mERROR[m i.a.i.d.b.BufferedStreamConsumer(close):215 - executing on failed close procedure.
2022-04-04 18:54:25 [43mdestination[0m > 2022-04-04 18:54:25 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):202 - Begin cleaning _airbyte_tmp_nfs_sftp_stage_powerschool_courses tmp table in destination.
2022-04-04 18:54:26 [43mdestination[0m > Exception in thread "main" java.lang.IllegalArgumentException: Message contained record from a stream that was not in the catalog. 
2022-04-04 18:54:26 [43mdestination[0m > catalog: {"streams":[{"stream":{"name":"sftp_stage_powerschool_courses","json_schema":{"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"ID":{"type":["number","null"]},"dcid":{"type":["number","null"]},"SchoolID":{"type":["number","null"]},"Add_to_GPA":{"type":["number","null"]},"Course_Name":{"type":["string","null"]},"Credit_Hours":{"type":["number","null"]},"Course_Number":{"type":["string","null"]}}},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"append","primary_key":[]}]} , 
2022-04-04 18:54:26 [43mdestination[0m > message: {"type":"RECORD","record":{"stream":"sftp_powerschool_courses_","data":{"Add_to_GPA":0,"dcid":1,"Course_Name":"INTRO CR ARTS","SchoolID":2681,"Credit_Hours":0.5,"Course_Number":"AR101","ID":1},"emitted_at":1649098462000}}
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.throwUnrecognizedStream(BufferedStreamConsumer.java:202)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:154)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-04 18:54:26 [43mdestination[0m > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:78)
2022-04-04 18:54:26 [43mdestination[0m > 2022-04-04 18:54:26 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):204 - _airbyte_tmp_nfs_sftp_stage_powerschool_courses tmp table in destination cleaned.
2022-04-04 18:54:26 [1;31mERROR[m i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination 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:164) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.35.64-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-04 18:54:26 [32mINFO[m i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@36472783[status=failed,recordsSynced=1837,bytesSynced=235570,startTime=1649098458660,endTime=1649098466175,totalStats=io.airbyte.config.SyncStats@7d571516[recordsEmitted=1837,bytesEmitted=235570,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@1cdd58c9[streamName=sftp_powerschool_courses_,stats=io.airbyte.config.SyncStats@345b383[recordsEmitted=1837,bytesEmitted=235570,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-04 18:54:26 [32mINFO[m i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-04 18:54:26 [33mWARN[m i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-04-04 18:54:26 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-04 18:54:26 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@5fe65b8d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@26f80956[status=failed,recordsSynced=1837,bytesSynced=235570,startTime=1649098458660,endTime=1649098466175,totalStats=io.airbyte.config.SyncStats@7d571516[recordsEmitted=1837,bytesEmitted=235570,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@1cdd58c9[streamName=sftp_powerschool_courses_,stats=io.airbyte.config.SyncStats@345b383[recordsEmitted=1837,bytesEmitted=235570,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2c48e9d[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@29b55cec[stream=io.airbyte.protocol.models.AirbyteStream@44e25064[name=sftp_stage_powerschool_courses,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"ID":{"type":["number","null"]},"dcid":{"type":["number","null"]},"SchoolID":{"type":["number","null"]},"Add_to_GPA":{"type":["number","null"]},"Course_Name":{"type":["string","null"]},"Credit_Hours":{"type":["number","null"]},"Course_Number":{"type":["string","null"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@22b65317[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@4a091ba[additionalProperties={attemptNumber=0, jobId=5132}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination 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$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1649098466173]]]
2022-04-04 18:54:26 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: does not have a value in the enumeration [HTTPS], $.storage: must be a constant value HTTPS
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: does not have a value in the enumeration [GCS], $.storage: must be a constant value GCS
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: does not have a value in the enumeration [S3], $.storage: must be a constant value S3
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage_account: is missing but it is required, $.storage: does not have a value in the enumeration [AzBlob], $.storage: must be a constant value AzBlob
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: does not have a value in the enumeration [SSH], $.storage: must be a constant value SSH
2022-04-04 18:54:26 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: does not have a value in the enumeration [SCP], $.storage: must be a constant value SCP