2022-05-30 20:57:30 [32mINFO[m i.a.s.a.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.0-alpha
2022-05-30 20:57:30 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):120 - Cloud storage job log path: /workspace/1148/0/logs.log
2022-05-30 20:57:34 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-05-30 20:57:30 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: 0.35.0-alpha
2022-05-30 20:57:30 [33mWARN[m i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-05-30 20:57:30 [32mINFO[m i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-30 20:57:30 [32mINFO[m i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-05-30 20:57:30 [32mINFO[m i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-05-30 20:57:30 [32mINFO[m i.a.w.DefaultReplicationWorker(run):99 - start sync worker. job id: 1148 attempt id: 0
2022-05-30 20:57:30 [32mINFO[m i.a.w.DefaultReplicationWorker(run):108 - configured sync modes: {null.braze_campaigns_conversion=full_refresh - append}
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubeProcessFactory(create):118 - Attempting to start pod = destination-redshift-sync-1148-0-idzns
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubeProcessFactory(create):121 - destination-redshift-sync-1148-0-idzns stdoutLocalPort = 9018
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubeProcessFactory(create):124 - destination-redshift-sync-1148-0-idzns stderrLocalPort = 9019
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):464 - Creating stdout socket server...
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):475 - Creating stderr socket server...
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubePodProcess(<init>):423 - Creating pod...
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):249 - Waiting for init container to be ready before copying files...
2022-05-30 20:57:30 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):252 - Init container present..
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):255 - Init container ready..
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(<init>):428 - Copying files...
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: destination_config.json
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: destination_catalog.json
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: FINISHED_UPLOADING
2022-05-30 20:57:32 [32mINFO[m i.a.w.p.KubePodProcess(<init>):431 - Waiting until pod is ready...
2022-05-30 20:57:33 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):466 - Setting stdout...
2022-05-30 20:57:33 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):477 - Setting stderr...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(<init>):445 - Reading pod IP...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(<init>):447 - Pod IP: 10.170.54.168
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(<init>):450 - Creating stdin socket...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubeProcessFactory(create):118 - Attempting to start pod = source-s3-sync-1148-0-atprw
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubeProcessFactory(create):121 - source-s3-sync-1148-0-atprw stdoutLocalPort = 9020
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubeProcessFactory(create):124 - source-s3-sync-1148-0-atprw stderrLocalPort = 9021
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):464 - Creating stdout socket server...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):475 - Creating stderr socket server...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(<init>):423 - Creating pod...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):249 - Waiting for init container to be ready before copying files...
2022-05-30 20:57:34 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):252 - Init container present..
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):255 - Init container ready..
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(<init>):428 - Copying files...
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: input_state.json
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: source_config.json
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: source_catalog.json
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: FINISHED_UPLOADING
2022-05-30 20:57:35 [32mINFO[m i.a.w.p.KubePodProcess(<init>):431 - Waiting until pod is ready...
2022-05-30 20:57:36 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):466 - Setting stdout...
2022-05-30 20:57:36 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):477 - Setting stderr...
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):445 - Reading pod IP...
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):447 - Pod IP: 10.170.45.129
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):454 - Using null stdin output stream...
2022-05-30 20:57:37 [32mINFO[m i.a.w.DefaultReplicationWorker(run):130 - Waiting for source and destination threads to complete.
2022-05-30 20:57:37 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):242 - Destination output thread started.
2022-05-30 20:57:37 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Replication thread started.
2022-05-30 20:57:39 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 1000
2022-05-30 20:57:40 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 2000
2022-05-30 20:57:40 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 3000
2022-05-30 20:57:40 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 4000
2022-05-30 20:57:40 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 5000
2022-05-30 20:57:40 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 6000
2022-05-30 20:57:41 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 7000
2022-05-30 20:57:41 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 8000
2022-05-30 20:57:41 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 9000
2022-05-30 20:57:41 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 10000
2022-05-30 20:57:42 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 11000
2022-05-30 20:57:42 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 12000
2022-05-30 20:57:42 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 13000
2022-05-30 20:57:42 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 14000
2022-05-30 20:57:42 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 15000
2022-05-30 20:57:43 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 16000
2022-05-30 20:57:43 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 17000
2022-05-30 20:57:43 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 18000
2022-05-30 20:57:43 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 19000
2022-05-30 20:57:44 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 20000
2022-05-30 20:57:44 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 21000
2022-05-30 20:57:44 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 22000
2022-05-30 20:57:44 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 23000
2022-05-30 20:57:45 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 24000
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.KubePodProcess(getReturnCode):634 - Exit code for pod source-s3-sync-1148-0-atprw is 0
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:15 [32mINFO[m i.a.w.DefaultReplicationWorker(run):135 - One of source or destination thread complete. Waiting on the other.
2022-05-30 20:57:34 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-30 20:57:34 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-30 20:57:34 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-05-30 20:57:34 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.d.r.RedshiftDestination(main):70 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [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-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [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-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [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-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3_WITH_SUPER_TMP_TYPE
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.d.s.S3DestinationConfig(createS3Client):165 - Creating S3 client...
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:34 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - initialised stream with format: 
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - initialised stream with format: 
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Starting syncing SourceS3
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - initialised stream with format: {'filetype': 'avro'}
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Syncing stream: braze_campaigns_conversion 
2022-05-30 20:57:37 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Iterating S3 bucket 'tgtg-braze-currents-production' with prefix: 'process/event_type=users.campaigns.Conversion/' 
2022-05-30 20:57:39 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - determined master schema: {'id': 'string', 'user_id': 'string', 'external_user_id': ['null', 'string'], 'app_id': ['null', 'string'], 'time': 'integer', 'timezone': ['null', 'string'], 'campaign_id': 'string', 'campaign_name': ['null', 'string'], 'message_variation_id': ['null', 'string'], 'send_id': ['null', 'string'], 'conversion_behavior_index': ['null', 'integer'], 'conversion_behavior': ['null', 'string']}
2022-05-30 20:57:40 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:40 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:41 [32mINFO[m i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing braze_campaigns_conversion: 8309 records (24 MB)
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:41 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:41 [32mINFO[m i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'braze_campaigns_conversion': s3://tgtg-data-raw-production/airbyte//braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:41 [32mINFO[m i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:41 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:41 [32mINFO[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to tgtg-data-raw-production/airbyte//braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv with full ID zNeNLtN0AeRskDND.JmEuJY.eNECIpaWzMMrcu4IEyMGybF1YObprRMgmPiQ_EfpOLSnSm20PHa1g0KJvHWmJ8teNmwq_XySDoBFCBM6RccyBE69SQTGUgZ08fNWwlcu
2022-05-30 20:57:42 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:42 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:43 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:43 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:57:43 [32mINFO[m i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing braze_campaigns_conversion: 8295 records (24 MB)
2022-05-30 20:57:43 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:44 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:44 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - finished reading a stream slice
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Read 24732 records from braze_campaigns_conversion stream
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing braze_campaigns_conversion
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - SourceS3 runtimes:
Syncing stream braze_campaigns_conversion 0:00:07.684398
2022-05-30 20:57:45 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing SourceS3
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Ideally, this situation should not happen...
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - The main thread is: main (RUNNABLE)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-1 (WAITING)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: java.base@17.0.1/jdk.internal.misc.Unsafe.park(Native Method)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.locks.LockSupport.park(LockSupport.java:341)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionNode.block(AbstractQueuedSynchronizer.java:506)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.unmanagedBlock(ForkJoinPool.java:3463)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3434)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1623)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:420)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:484)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-2 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-3 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-4 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-5 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-6 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-7 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-8 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-9 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-10 (BLOCKED)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 -         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing braze_campaigns_conversion: 8128 records (24 MB)
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'braze_campaigns_conversion'.
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [32mINFO[m a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-05-30 20:58:15 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:15 [33mWARN[m a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-05-30 20:58:16 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:16 [32mINFO[m a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to tgtg-data-raw-production/airbyte//braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv with id zNeNLtN0A...08fNWwlcu]: Finished uploading [Part number 2 containing 11.51 MB]
2022-05-30 20:58:16 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:16 [32mINFO[m a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to tgtg-data-raw-production/airbyte//braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv with id zNeNLtN0A...08fNWwlcu]: Finished uploading [Part number 1 containing 10.01 MB]
2022-05-30 20:58:16 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:16 [32mINFO[m a.m.s.StreamTransferManager(complete):395 - [Manager uploading to tgtg-data-raw-production/airbyte//braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv with id zNeNLtN0A...08fNWwlcu]: Completed
2022-05-30 20:58:16 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:16 [32mINFO[m i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'braze_campaigns_conversion'.
2022-05-30 20:58:16 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:16 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: tgtg_raw
2022-05-30 20:58:17 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:17 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: braze_campaigns_conversion, schema: tgtg_raw, tmp table name: _airbyte_tmp_flx_braze_campaigns_conversion.
2022-05-30 20:58:18 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:18 [32mINFO[m i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_flx_braze_campaigns_conversion in destination for stream: braze_campaigns_conversion, schema: tgtg_raw, .
2022-05-30 20:58:21 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:21 [32mINFO[m i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_flx_braze_campaigns_conversion in destination for stream braze_campaigns_conversion complete.
2022-05-30 20:58:21 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:21 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_braze_campaigns_conversion in destination.
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_flx_braze_campaigns_conversion in destination prepared.
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_flx_braze_campaigns_conversion to dest table: _airbyte_raw_braze_campaigns_conversion, schema: tgtg_raw, in destination.
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.r.RedshiftSqlOperations(onDestinationCloseOperations):110 - Executing operations for Redshift Destination DB engine...
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):129 - Discovering NOT SUPER table types...
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [1;31mERROR[m i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):146 - Error during discoverNotSuperTables() appears: 
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Position: 20;
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Position: 20;
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	... 13 more
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file /braze_campaigns_conversion/2022_05_30_1653944254911_bf8097f5-f65d-4233-bc3f-ee837b4085d2.csv cleaned.
2022-05-30 20:58:22 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:22 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_flx_braze_campaigns_conversion tmp table in destination.
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:24 [32mINFO[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_flx_braze_campaigns_conversion tmp table in destination cleaned.
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:24 [32mINFO[m i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file /5f3fcb31-e34c-47c9-88a5-e9f9d31e3243/tgtg_raw/d3e1ee92-660d-40fc-96f3-c03e4bf7f140.manifest.
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:24 [32mINFO[m i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file /5f3fcb31-e34c-47c9-88a5-e9f9d31e3243/tgtg_raw/d3e1ee92-660d-40fc-96f3-c03e4bf7f140.manifest cleaned.
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-05-30 20:58:24 [1;31mERROR[m i.a.i.d.b.BufferedStreamConsumer(close):191 - Close failed.
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Position: 20;
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.lambda$onDestinationCloseOperations$0(RedshiftSqlOperations.java:113) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Exception in thread "main" java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.closeAsOneTransaction(CopyConsumerFactory.java:160) ~[io.airbyte.airbyte-integrations.connectors-destination-jdbc-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Position: 20;
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.lambda$onCloseFunction$3(CopyConsumerFactory.java:126) ~[io.airbyte.airbyte-integrations.connectors-destination-jdbc-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction.accept(OnCloseFunction.java:9) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.lambda$onDestinationCloseOperations$0(RedshiftSqlOperations.java:113)
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:179) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71) [io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Position: 20;
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.closeAsOneTransaction(CopyConsumerFactory.java:160)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.lambda$onCloseFunction$3(CopyConsumerFactory.java:126)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction.accept(OnCloseFunction.java:9)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:179)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Position: 20;
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - Position: 20;
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source)
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - Position: 20;
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):82 - 	... 13 more
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-05-30 20:58:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(getReturnCode):634 - Exit code for pod destination-redshift-sync-1148-0-idzns is 1
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod source-s3-sync-1148-0-atprw
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod destination-redshift-sync-1148-0-idzns
2022-05-30 20:58:54 [1;31mERROR[m i.a.w.DefaultReplicationWorker(run):141 - Sync worker failed.
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: 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:136) ~[io.airbyte-airbyte-workers-0.35.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.35.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.0-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.0-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:118) ~[io.airbyte-airbyte-workers-0.35.0-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.35.0-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.0-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$3(DefaultReplicationWorker.java:260) ~[io.airbyte-airbyte-workers-0.35.0-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: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$3(DefaultReplicationWorker.java:252) ~[io.airbyte-airbyte-workers-0.35.0-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-05-30 20:58:54 [32mINFO[m i.a.w.DefaultReplicationWorker(run):165 - sync summary: io.airbyte.config.ReplicationAttemptSummary@2649216d[status=failed,recordsSynced=24732,bytesSynced=19525981,startTime=1653944250567,endTime=1653944334759]
2022-05-30 20:58:54 [32mINFO[m i.a.w.DefaultReplicationWorker(run):174 - Source did not output any state messages
2022-05-30 20:58:54 [33mWARN[m i.a.w.DefaultReplicationWorker(run):182 - State capture: No new state, falling back on input state: io.airbyte.config.State@7eeb8505[state={}]
2022-05-30 20:58:54 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-05-30 20:58:54 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(replicate):144 - sync summary: io.airbyte.config.StandardSyncOutput@294c9c1e[standardSyncSummary=io.airbyte.config.StandardSyncSummary@76db94f5[status=failed,recordsSynced=24732,bytesSynced=19525981,startTime=1653944250567,endTime=1653944334759],state=io.airbyte.config.State@7eeb8505[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@4a83cb2c[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2554499b[stream=io.airbyte.protocol.models.AirbyteStream@68358d43[name=braze_campaigns_conversion,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"time":{"type":["null","integer"]},"app_id":{"type":["null",["null","string"]]},"send_id":{"type":["null",["null","string"]]},"user_id":{"type":["null","string"]},"timezone":{"type":["null",["null","string"]]},"campaign_id":{"type":["null","string"]},"campaign_name":{"type":["null",["null","string"]]},"external_user_id":{"type":["null",["null","string"]]},"_ab_source_file_url":{"type":"string"},"conversion_behavior":{"type":["null",["null","string"]]},"message_variation_id":{"type":["null",["null","string"]]},"_ab_additional_properties":{"type":"object"},"conversion_behavior_index":{"type":["null",["null","integer"]]},"_ab_source_file_last_modified":{"type":"string","format":"date-time"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[_ab_source_file_last_modified],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[_ab_source_file_last_modified],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2022-05-30 20:58:54 [32mINFO[m i.a.c.p.ConfigRepository(updateConnectionState):537 - Updating connection 288b34b9-6044-4d4d-b3c1-c427ddbf264b state: io.airbyte.config.State@9d237f9[state={}]
2022-05-30 20:58:54 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):120 - Cloud storage job log path: /workspace/1148/0/logs.log
2022-05-30 20:58:54 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: 0.35.0-alpha
2022-05-30 20:58:54 [33mWARN[m i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-05-30 20:58:54 [32mINFO[m i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-30 20:58:54 [32mINFO[m i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-05-30 20:58:54 [32mINFO[m i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-05-30 20:58:54 [32mINFO[m i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-05-30 20:58:54 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.61
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubeProcessFactory(create):118 - Attempting to start pod = normalization-sync-1148-0-epnug
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubeProcessFactory(create):121 - normalization-sync-1148-0-epnug stdoutLocalPort = 9026
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubeProcessFactory(create):124 - normalization-sync-1148-0-epnug stderrLocalPort = 9027
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):464 - Creating stdout socket server...
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):475 - Creating stderr socket server...
2022-05-30 20:58:54 [32mINFO[m i.a.w.p.KubePodProcess(<init>):423 - Creating pod...
2022-05-30 20:58:55 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):249 - Waiting for init container to be ready before copying files...
2022-05-30 20:58:55 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):252 - Init container present..
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):255 - Init container ready..
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(<init>):428 - Copying files...
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: destination_config.json
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: destination_catalog.json
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):228 - Uploading file: FINISHED_UPLOADING
2022-05-30 20:58:56 [32mINFO[m i.a.w.p.KubePodProcess(<init>):431 - Waiting until pod is ready...
2022-05-30 20:58:57 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):466 - Setting stdout...
2022-05-30 20:58:57 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):477 - Setting stderr...
2022-05-30 20:58:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):445 - Reading pod IP...
2022-05-30 20:58:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):447 - Pod IP: 10.170.45.129
2022-05-30 20:58:58 [32mINFO[m i.a.w.p.KubePodProcess(<init>):454 - Using null stdin output stream...
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(getReturnCode):634 - Exit code for pod normalization-sync-1148-0-epnug is 0
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):649 - Closed all resources for pod normalization-sync-1148-0-epnug
2022-05-30 20:59:05 [32mINFO[m i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 10 seconds.
2022-05-30 20:59:05 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Running: transform-config --config destination_config.json --integration-type redshift --out /config
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Namespace(config='destination_config.json', integration_type=<DestinationType.redshift: 'redshift'>, out='/config')
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - transform_redshift
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Running: transform-catalog --integration-type redshift --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Processing destination_catalog.json...
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 -   Generating airbyte_ctes/tgtg_raw/braze_campaigns_conversion_ab1.sql from braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column app_id at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column send_id at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column timezone at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column campaign_name at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column external_user_id at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column conversion_behavior at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'string']] for column message_variation_id at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - WARN: Unknown type ['null', ['null', 'integer']] for column conversion_behavior_index at braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 -   Generating airbyte_ctes/tgtg_raw/braze_campaigns_conversion_ab2.sql from braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 -   Generating airbyte_ctes/tgtg_raw/braze_campaigns_conversion_ab3.sql from braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 -   Generating airbyte_incremental/tgtg_raw/braze_campaigns_conversion.sql from braze_campaigns_conversion
2022-05-30 20:58:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - detected no config file for ssh, assuming ssh is off.
2022-05-30 20:58:59 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Running with dbt=0.21.1
2022-05-30 20:58:59 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - [[33mWARNING[0m]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - There are 2 unused configuration paths:
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_views
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_tables
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Found 4 models, 0 tests, 0 snapshots, 0 analyses, 505 macros, 0 operations, 0 seed files, 1 source, 0 exposures
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:00 | Concurrency: 32 threads (target='prod')
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:00 | 
2022-05-30 20:59:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:00 | 1 of 1 START incremental model tgtg_raw.braze_campaigns_conversion........................................... [RUN]
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:04 | 1 of 1 OK created incremental model tgtg_raw.braze_campaigns_conversion...................................... [[32mINSERT 0 0[0m in 3.42s]
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:04 | 
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 20:59:04 | Finished running 1 incremental model in 3.77s.
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - [32mCompleted successfully[0m
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - 
2022-05-30 20:59:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1