2022-04-22 14:18:49 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.47-alpha
2022-04-22 14:18:49 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/253/0/logs.log
2022-04-22 14:18:49 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.47-alpha
2022-04-22 14:18:49 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 253 attempt id: 0
2022-04-22 14:18:49 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.ticket_metrics=incremental - append}
2022-04-22 14:18:49 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-22 14:18:49 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.32 exists...
2022-04-22 14:18:49 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.32 was found locally.
2022-04-22 14:18:49 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 253
2022-04-22 14:18:49 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/253/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-redshift:0.3.32 write --config destination_config.json --catalog destination_catalog.json
2022-04-22 14:18:49 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-zendesk-support:0.2.6 exists...
2022-04-22 14:18:49 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-zendesk-support:0.2.6 was found locally.
2022-04-22 14:18:49 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 253
2022-04-22 14:18:49 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/253/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-zendesk-support:0.2.6 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-22 14:18:49 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started.
2022-04-22 14:18:49 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-04-22 14:18:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-04-22 14:18:50 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-22 14:18:50 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-22 14:18:50 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-22 14:18:50 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-22 14:18:50 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-22 14:18:51 source > Starting syncing SourceZendeskSupport
2022-04-22 14:18:51 source > Syncing stream: ticket_metrics 
2022-04-22 14:18:51 destination > 2022-04-22 14:18:51 INFO i.a.i.d.r.RedshiftDestination(main):70 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 14:18:52 destination > 2022-04-22 14:18:52 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3_WITH_SUPER_TMP_TYPE
2022-04-22 14:18:53 destination > 2022-04-22 14:18:53 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):165 - Creating S3 client...
2022-04-22 14:18:54 destination > 2022-04-22 14:18:54 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-22 14:18:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 1000
2022-04-22 14:18:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 2000
2022-04-22 14:19:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 3000
2022-04-22 14:19:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 4000
2022-04-22 14:19:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 5000
2022-04-22 14:19:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 6000
2022-04-22 14:19:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 7000
2022-04-22 14:19:04 destination > 2022-04-22 14:19:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7200 records (24 MB)
2022-04-22 14:19:04 destination > 2022-04-22 14:19:04 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 14:19:04 destination > 2022-04-22 14:19:04 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metrics': s3://bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv
2022-04-22 14:19:04 destination > 2022-04-22 14:19:04 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 14:19:05 destination > 2022-04-22 14:19:05 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv with full ID b.t57lcLbvDRaFLDJvmvWPnAjGGLzki.pdv8PmkCN5bxp9aSc61eLfolSPbpYXS5PQNCeq.MxLZ3zWEu5SGPFZlHKWLgPQN.kvuH6ZngoZeVlOGUuEULeyNUvDxDLpjP
2022-04-22 14:19:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 8000
2022-04-22 14:19:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 9000
2022-04-22 14:19:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 10000
2022-04-22 14:19:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 11000
2022-04-22 14:19:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 12000
2022-04-22 14:19:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 13000
2022-04-22 14:19:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 14000
2022-04-22 14:19:11 destination > 2022-04-22 14:19:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7184 records (24 MB)
2022-04-22 14:19:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 15000
2022-04-22 14:19:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 16000
2022-04-22 14:19:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 17000
2022-04-22 14:19:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 18000
2022-04-22 14:19:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 19000
2022-04-22 14:19:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 20000
2022-04-22 14:19:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 21000
2022-04-22 14:19:29 destination > 2022-04-22 14:19:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7164 records (24 MB)
2022-04-22 14:19:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 22000
2022-04-22 14:19:30 destination > 2022-04-22 14:19:30 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv with id b.t57lcLb...UvDxDLpjP]: Finished uploading [Part number 1 containing 10.01 MB]
2022-04-22 14:19:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 23000
2022-04-22 14:19:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 24000
2022-04-22 14:19:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 25000
2022-04-22 14:19:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 26000
2022-04-22 14:19:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 27000
2022-04-22 14:19:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 28000
2022-04-22 14:19:48 destination > 2022-04-22 14:19:48 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7162 records (24 MB)
2022-04-22 14:19:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 29000
2022-04-22 14:19:48 destination > 2022-04-22 14:19:48 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv with id b.t57lcLb...UvDxDLpjP]: Finished uploading [Part number 2 containing 10.01 MB]
2022-04-22 14:19:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 30000
2022-04-22 14:19:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 31000
2022-04-22 14:19:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 32000
2022-04-22 14:20:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 33000
2022-04-22 14:20:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 34000
2022-04-22 14:20:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 35000
2022-04-22 14:20:05 destination > 2022-04-22 14:20:05 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7169 records (24 MB)
2022-04-22 14:20:05 destination > 2022-04-22 14:20:05 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 14:20:05 destination > 2022-04-22 14:20:05 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metrics': s3://bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv
2022-04-22 14:20:05 destination > 2022-04-22 14:20:05 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 14:20:05 destination > 2022-04-22 14:20:05 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv with full ID FqKWogYhyABN53p9QiFA1cKXL15MXOEWifDLFEnMnUkPrNW6fJU_V5FjMa07WfggEYFgry0TmFZvUlWyteFsy15LdgJ7RZMPbleHB4I1bHrIyVq56vbqIxDRgNAX_xh3
2022-04-22 14:20:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 36000
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'ticket_metrics'.
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv with id b.t57lcLb...UvDxDLpjP]: Finished uploading [Part number 3 containing 9.18 MB]
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_ee8f2ee1-1687-4044-a5fa-2c3b48d56cd2.csv with id b.t57lcLb...UvDxDLpjP]: Completed
2022-04-22 14:20:06 destination > 2022-04-22 14:20:06 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'ticket_metrics'.
2022-04-22 14:20:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 37000
2022-04-22 14:20:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 38000
2022-04-22 14:20:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 39000
2022-04-22 14:20:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 40000
2022-04-22 14:20:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 41000
2022-04-22 14:20:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 42000
2022-04-22 14:20:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 43000
2022-04-22 14:20:24 destination > 2022-04-22 14:20:24 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7168 records (24 MB)
2022-04-22 14:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 44000
2022-04-22 14:20:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 45000
2022-04-22 14:20:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 46000
2022-04-22 14:20:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 47000
2022-04-22 14:20:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 48000
2022-04-22 14:20:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 49000
2022-04-22 14:20:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 50000
2022-04-22 14:20:42 destination > 2022-04-22 14:20:42 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7155 records (24 MB)
2022-04-22 14:20:42 destination > 2022-04-22 14:20:42 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv with id FqKWogYhy...RgNAX_xh3]: Finished uploading [Part number 1 containing 10.01 MB]
2022-04-22 14:20:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 51000
2022-04-22 14:20:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 52000
2022-04-22 14:20:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 53000
2022-04-22 14:20:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 54000
2022-04-22 14:20:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 55000
2022-04-22 14:20:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 56000
2022-04-22 14:21:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 57000
2022-04-22 14:21:03 destination > 2022-04-22 14:21:03 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7168 records (24 MB)
2022-04-22 14:21:04 destination > 2022-04-22 14:21:04 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv with id FqKWogYhy...RgNAX_xh3]: Finished uploading [Part number 2 containing 10.01 MB]
2022-04-22 14:21:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 58000
2022-04-22 14:21:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 59000
2022-04-22 14:21:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 60000
2022-04-22 14:21:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 61000
2022-04-23 17:28:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 62000
2022-04-23 17:28:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 63000
2022-04-23 17:28:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 64000
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7164 records (24 MB)
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metrics': s3://bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv with full ID WNCwgvL1noWDtKDqCbCvbA6GzqtOvONlcsbe8Zb0noBDOAGV0byasUOTPCL9kd_4pdOkizxzEuqYb1VPypKiYbNbndS8..genLnmsvZijjaO2iJNrTH2QZ1rAETfHdx_
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'ticket_metrics'.
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-23 17:28:16 destination > 2022-04-23 17:28:16 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv with id FqKWogYhy...RgNAX_xh3]: Finished uploading [Part number 3 containing 9.16 MB]
2022-04-23 17:28:17 destination > 2022-04-23 17:28:17 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_e254d360-a54a-434a-89ac-97bc6f6422ae.csv with id FqKWogYhy...RgNAX_xh3]: Completed
2022-04-23 17:28:17 destination > 2022-04-23 17:28:17 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'ticket_metrics'.
2022-04-23 17:28:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 65000
2022-04-23 17:28:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 66000
2022-04-23 17:28:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 67000
2022-04-23 17:28:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 68000
2022-04-23 17:28:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 69000
2022-04-23 17:28:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 70000
2022-04-23 17:28:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 71000
2022-04-23 17:28:22 destination > 2022-04-23 17:28:22 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7166 records (24 MB)
2022-04-23 17:28:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 72000
2022-04-23 17:28:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 73000
2022-04-23 17:28:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 74000
2022-04-23 17:28:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 75000
2022-04-23 17:28:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 76000
2022-04-23 17:28:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 77000
2022-04-23 17:28:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 78000
2022-04-23 17:28:28 destination > 2022-04-23 17:28:28 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7165 records (24 MB)
2022-04-23 17:28:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 79000
2022-04-23 17:28:28 destination > 2022-04-23 17:28:28 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv with id WNCwgvL1n...rAETfHdx_]: Finished uploading [Part number 1 containing 10.01 MB]
2022-04-23 17:28:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 80000
2022-04-23 17:28:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 81000
2022-04-23 17:28:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 82000
2022-04-23 17:28:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 83000
2022-04-23 17:28:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 84000
2022-04-23 17:28:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 85000
2022-04-23 17:28:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 86000
2022-04-23 17:28:33 destination > 2022-04-23 17:28:33 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7165 records (24 MB)
2022-04-23 17:28:34 destination > 2022-04-23 17:28:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv with id WNCwgvL1n...rAETfHdx_]: Finished uploading [Part number 2 containing 10.01 MB]
2022-04-23 17:28:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 87000
2022-04-23 17:28:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 88000
2022-04-23 17:28:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 89000
2022-04-23 17:28:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 90000
2022-04-23 17:28:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 91000
2022-04-23 17:28:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 92000
2022-04-23 17:28:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 93000
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7153 records (24 MB)
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'ticket_metrics': s3://bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_65ba6b00-151c-42d6-b911-64784d4098bb.csv
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_65ba6b00-151c-42d6-b911-64784d4098bb.csv with full ID eT7vy3ir8qOq83MdrushRWDa1LRT0MAuowRBUnv.BFZIc608MlLpi1.O86JdibxCQgEq30qfLIjvLEz7pi5kovm.HcTczDjC_BQ01Su8TcfrclXuTuScN.eaz171afzb
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'ticket_metrics'.
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-23 17:28:39 destination > 2022-04-23 17:28:39 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv with id WNCwgvL1n...rAETfHdx_]: Finished uploading [Part number 3 containing 9.17 MB]
2022-04-23 17:28:40 destination > 2022-04-23 17:28:40 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_4c7688ed-4202-44a6-8225-4e1ad75a1ad5.csv with id WNCwgvL1n...rAETfHdx_]: Completed
2022-04-23 17:28:40 destination > 2022-04-23 17:28:40 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'ticket_metrics'.
2022-04-23 17:28:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 94000
2022-04-23 17:28:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 95000
2022-04-23 17:28:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 96000
2022-04-23 17:28:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 97000
2022-04-23 17:28:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 98000
2022-04-23 17:28:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 99000
2022-04-23 17:28:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 100000
2022-04-23 17:28:45 destination > 2022-04-23 17:28:45 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 7147 records (24 MB)
2022-04-23 17:28:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 101000
2022-04-23 17:28:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 102000
2022-04-23 17:28:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 103000
2022-04-23 17:28:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 104000
2022-04-23 17:28:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 105000
2022-04-23 17:28:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 106000
2022-04-23 21:49:04 source > Read 106921 records from ticket_metrics stream
2022-04-23 21:49:04 source > Finished syncing ticket_metrics
2022-04-23 21:49:04 source > SourceZendeskSupport runtimes:
Syncing stream ticket_metrics 1 day, 7:30:13.085177
2022-04-23 21:49:04 source > Finished syncing SourceZendeskSupport
2022-04-23 21:49:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 106922
2022-04-23 21:49:04 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-04-23 21:49:04 destination > Ideally, this situation should not happen...
2022-04-23 21:49:04 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-04-23 21:49:04 destination > The main thread is: main (RUNNABLE)
2022-04-23 21:49:04 destination >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-23 21:49:04 destination >         at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-1 (WAITING)
2022-04-23 21:49:04 destination >  Thread stacktrace: java.base@17.0.1/jdk.internal.misc.Unsafe.park(Native Method)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.locks.LockSupport.park(LockSupport.java:341)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionNode.block(AbstractQueuedSynchronizer.java:506)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.unmanagedBlock(ForkJoinPool.java:3463)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3434)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1623)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:420)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:484)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-2 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-3 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-4 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-5 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-6 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-7 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-8 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-9 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-5-thread-10 (BLOCKED)
2022-04-23 21:49:04 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-04-23 21:49:04 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:04 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-23 21:49:04 destination > 2022-04-23 21:49:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing ticket_metrics: 6591 records (23 MB)
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'ticket_metrics'.
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_65ba6b00-151c-42d6-b911-64784d4098bb.csv with id eT7vy3ir8...az171afzb]: Finished uploading [Part number 1 containing 10.01 MB]
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_65ba6b00-151c-42d6-b911-64784d4098bb.csv with id eT7vy3ir8...az171afzb]: Finished uploading [Part number 2 containing 11.33 MB]
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to bi-airbyte-import/zendesk_support/ticket_metrics/2022_04_22_1650637134065_65ba6b00-151c-42d6-b911-64784d4098bb.csv with id eT7vy3ir8...az171afzb]: Completed
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'ticket_metrics'.
2022-04-23 21:49:05 destination > 2022-04-23 21:49:05 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: cc
2022-04-23 21:49:06 destination > 2022-04-23 21:49:06 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: ticket_metrics, schema: cc, tmp table name: _airbyte_tmp_tvw_ticket_metrics.
2022-04-23 21:49:07 destination > 2022-04-23 21:49:07 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_tvw_ticket_metrics in destination for stream: ticket_metrics, schema: cc, .
2022-04-23 21:49:09 destination > 2022-04-23 21:49:09 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_tvw_ticket_metrics in destination for stream ticket_metrics complete.
2022-04-23 21:49:09 destination > 2022-04-23 21:49:09 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_ticket_metrics in destination.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_tvw_ticket_metrics in destination prepared.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_tvw_ticket_metrics to dest table: _airbyte_raw_ticket_metrics, schema: cc, in destination.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.r.RedshiftSqlOperations(onDestinationCloseOperations):110 - Executing operations for Redshift Destination DB engine...
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):129 - Discovering NOT SUPER table types...
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 ERROR i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):146 - Error during discoverNotSuperTables() appears: 
2022-04-23 21:49:10 destination > java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:10 destination > Position: 20;
2022-04-23 21:49:10 destination > 	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-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:10 destination > 	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-04-23 21:49:10 destination > 	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-04-23 21:49:10 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-23 21:49:10 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:10 destination > Position: 20;
2022-04-23 21:49:10 destination > 	... 13 more
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_tvw_ticket_metrics tmp table in destination.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_tvw_ticket_metrics tmp table in destination cleaned.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file zendesk_support/4788c858-5b5c-4e5c-a756-0765c993b426/cc/7b54ea50-feab-48d8-8175-867c865fd006.manifest.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file zendesk_support/4788c858-5b5c-4e5c-a756-0765c993b426/cc/7b54ea50-feab-48d8-8175-867c865fd006.manifest cleaned.
2022-04-23 21:49:10 destination > 2022-04-23 21:49:10 ERROR i.a.i.d.b.BufferedStreamConsumer(close):191 - Close failed.
2022-04-23 21:49:10 destination > java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:10 destination > Position: 20;
2022-04-23 21:49:10 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-23 21:49:10 destination > 	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-04-23 21:49:10 destination > 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616) ~[?:?]
2022-04-23 21:49:10 destination > 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622) ~[?:?]
2022-04-23 21:49:11 destination > 	at java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627) ~[?:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71) [io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-23 21:49:11 destination > Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:11 destination > Position: 20;
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-23 21:49:11 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-23 21:49:11 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-23 21:49:11 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:11 destination > Position: 20;
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-23 21:49:11 destination > Exception in thread "main" java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:11 destination > Position: 20;
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147)
2022-04-23 21:49:11 destination > 	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-04-23 21:49:11 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.lambda$onDestinationCloseOperations$0(RedshiftSqlOperations.java:113)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273)
2022-04-23 21:49:11 destination > 	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
2022-04-23 21:49:11 destination > 	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.closeAsOneTransaction(CopyConsumerFactory.java:160)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.lambda$onCloseFunction$3(CopyConsumerFactory.java:126)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction.accept(OnCloseFunction.java:9)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:182)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-23 21:49:11 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71)
2022-04-23 21:49:11 destination > Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:11 destination > Position: 20;
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source)
2022-04-23 21:49:11 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-23 21:49:11 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-04-23 21:49:11 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-04-23 21:49:11 destination > 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-23 21:49:11 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-23 21:49:11 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-23 21:49:11 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-23 21:49:11 destination > Position: 20;
2022-04-23 21:49:11 destination > 	... 13 more
2022-04-23 21:49:11 ERROR i.a.w.DefaultReplicationWorker(run):168 - 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:163) ~[io.airbyte-airbyte-workers-0.35.47-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.47-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.47-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.47-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.47-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.47-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.47-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:353) ~[io.airbyte-airbyte-workers-0.35.47-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-23 21:49:11 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@7a210cdd[status=failed,recordsSynced=106921,bytesSynced=97860434,startTime=1650637129296,endTime=1650750551155,totalStats=io.airbyte.config.SyncStats@1c5f2f24[recordsEmitted=106921,bytesEmitted=97860434,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@403caa12[streamName=ticket_metrics,stats=io.airbyte.config.SyncStats@374b0e6d[recordsEmitted=106921,bytesEmitted=97860434,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-23 21:49:11 INFO i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-04-23 21:49:11 WARN i.a.w.DefaultReplicationWorker(run):257 - State capture: No new state, falling back on input state: io.airbyte.config.State@457ebbbd[state={}]
2022-04-23 21:49:11 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-23 21:49:11 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@622ec151[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2e7a0405[status=failed,recordsSynced=106921,bytesSynced=97860434,startTime=1650637129296,endTime=1650750551155,totalStats=io.airbyte.config.SyncStats@1c5f2f24[recordsEmitted=106921,bytesEmitted=97860434,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@403caa12[streamName=ticket_metrics,stats=io.airbyte.config.SyncStats@374b0e6d[recordsEmitted=106921,bytesEmitted=97860434,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=io.airbyte.config.State@457ebbbd[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@1a91c09e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@7f00a434[stream=io.airbyte.protocol.models.AirbyteStream@6b30d6cc[name=ticket_metrics,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"time":{"type":["null","string"]},"type":{"type":["null","string"]},"metric":{"type":["null","string"]},"status":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"reopens":{"type":["null","integer"]},"replies":{"type":["null","integer"]},"solved_at":{"type":["null","string"],"format":"date-time"},"ticket_id":{"type":["null","integer"]},"created_at":{"type":["null","string"],"format":"date-time"},"updated_at":{"type":["null","string"],"format":"date-time"},"assigned_at":{"type":["null","string"],"format":"date-time"},"instance_id":{"type":["null","integer"]},"group_stations":{"type":["null","integer"]},"assignee_stations":{"type":["null","integer"]},"status_updated_at":{"type":["null","string"],"format":"date-time"},"assignee_updated_at":{"type":["null","string"],"format":"date-time"},"requester_updated_at":{"type":["null","string"],"format":"date-time"},"initially_assigned_at":{"type":["null","string"],"format":"date-time"},"reply_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"latest_comment_added_at":{"type":["null","string"],"format":"date-time"},"on_hold_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"agent_wait_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"requester_wait_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"full_resolution_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}},"first_resolution_time_in_minutes":{"type":["null","object"],"properties":{"business":{"type":["null","integer"]},"calendar":{"type":["null","integer"]}}}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@1514bd83[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@1950a8f[additionalProperties={attemptNumber=0, jobId=253}],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:353)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1650750551154]]]
2022-04-23 21:49:11 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-23 21:49:11 INFO i.a.c.p.ConfigRepository(updateConnectionState):594 - Updating connection f2f02790-9f7e-4bb2-83c2-7fc8aa7be70c state: io.airbyte.config.State@266d5f6c[state={}]
2022-04-23 21:49:11 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.credentials: must be a constant value oauth2.0