2022-04-25 14:47:58 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.2-alpha 2022-04-25 14:47:58 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/15/1/logs.log 2022-04-25 14:48:02 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-25 14:47:58 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.2-alpha 2022-04-25 14:47:58 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 15 attempt id: 1 2022-04-25 14:47:58 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.tickets=incremental - append, null.ticket_comments=incremental - append, null.ticket_fields=incremental - append, null.ticket_audits=full_refresh - append, null.ticket_metric_events=incremental - append, null.ticket_forms=full_refresh - append, null.ticket_metrics=incremental - append, null.users=incremental - append} 2022-04-25 14:47:58 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-25 14:47:58 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-gcs-sync-15-1-zdkwg for airbyte/destination-gcs:0.2.4 2022-04-25 14:47:58 INFO i.a.w.p.KubeProcessFactory(create):116 - destination-gcs-sync-15-1-zdkwg stdoutLocalPort = 9026 2022-04-25 14:47:58 INFO i.a.w.p.KubeProcessFactory(create):119 - destination-gcs-sync-15-1-zdkwg stderrLocalPort = 9027 2022-04-25 14:47:58 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server... 2022-04-25 14:47:58 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server... 2022-04-25 14:47:58 INFO i.a.w.p.KubePodProcess():512 - Creating pod destination-gcs-sync-15-1-zdkwg... 2022-04-25 14:47:58 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-25 14:47:58 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess():543 - Copying files... 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/cbae76d0-3bb1-4660-8f4c-295fa82ff408/destination_config.json airbyte/destination-gcs-sync-15-1-zdkwg:/config/destination_config.json -c init 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/7277e169-7eab-4b58-b228-bed6de1f093d/destination_catalog.json airbyte/destination-gcs-sync-15-1-zdkwg:/config/destination_catalog.json -c init 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/38099e3c-f792-45c7-965e-ed2d593985d8/FINISHED_UPLOADING airbyte/destination-gcs-sync-15-1-zdkwg:/config/FINISHED_UPLOADING -c init 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:00 INFO i.a.w.p.KubePodProcess():546 - Waiting until pod is ready... 2022-04-25 14:48:01 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout... 2022-04-25 14:48:01 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess():561 - Reading pod IP... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess():563 - Pod IP: 10.112.0.190 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess():566 - Creating stdin socket... 2022-04-25 14:48:02 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = source-zendesk-support-sync-15-1-nbjao for airbyte/source-zendesk-support:0.2.6 2022-04-25 14:48:02 INFO i.a.w.p.KubeProcessFactory(create):116 - source-zendesk-support-sync-15-1-nbjao stdoutLocalPort = 9028 2022-04-25 14:48:02 INFO i.a.w.p.KubeProcessFactory(create):119 - source-zendesk-support-sync-15-1-nbjao stderrLocalPort = 9029 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess():512 - Creating pod source-zendesk-support-sync-15-1-nbjao... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-25 14:48:02 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess():543 - Copying files... 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/c39712cb-4549-4478-ac08-7b6ce4dfad81/input_state.json airbyte/source-zendesk-support-sync-15-1-nbjao:/config/input_state.json -c init 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/fea2c256-af91-47a0-88e3-f3483914acf0/source_config.json airbyte/source-zendesk-support-sync-15-1-nbjao:/config/source_config.json -c init 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/d74b1926-a554-4f7b-8675-dc1605c1773d/source_catalog.json airbyte/source-zendesk-support-sync-15-1-nbjao:/config/source_catalog.json -c init 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/63da356b-21bd-4c14-9224-5511547eef96/FINISHED_UPLOADING airbyte/source-zendesk-support-sync-15-1-nbjao:/config/FINISHED_UPLOADING -c init 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-25 14:48:03 INFO i.a.w.p.KubePodProcess():546 - Waiting until pod is ready... 2022-04-25 14:48:04 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout... 2022-04-25 14:48:04 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr... 2022-04-25 14:48:05 INFO i.a.w.p.KubePodProcess():561 - Reading pod IP... 2022-04-25 14:48:05 INFO i.a.w.p.KubePodProcess():563 - Pod IP: 10.112.0.96 2022-04-25 14:48:05 INFO i.a.w.p.KubePodProcess():570 - Using null stdin output stream... 2022-04-25 14:48:05 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-25 14:48:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-25 14:48:05 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-25 14:48:15 INFO i.a.w.p.KubePodProcess(close):710 - (pod: airbyte / destination-gcs-sync-15-1-zdkwg) - Closed all resources for pod 2022-04-25 14:48:02 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-25 14:48:02 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-25 14:48:02 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-25 14:48:02 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.gcs.GcsDestination 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 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-25 14:48:05 destination > 2022-04-25 14:48:02 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 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-25 14:48:05 destination > 2022-04-25 14:48:02 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-25 14:48:05 destination > 2022-04-25 14:48:02 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword requires - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-25 14:48:05 destination > 2022-04-25 14:48:02 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"Parquet","page_size_kb":1024,"block_size_mb":128,"compression_codec":"SNAPPY","dictionary_encoding":true,"max_padding_size_mb":8,"dictionary_page_size_kb":1024} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.SerializedBufferFactory(getCreateFunction):49 - S3 format config: S3ParquetFormatConfig{compressionCodec=SNAPPY, blockSize=134217728, maxPaddingSize=8388608, pageSize=1048576, dictionaryPageSize=1048576, dictionaryEncoding=true, } 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_audits, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_audits/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_comments, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_comments/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_fields, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_fields/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_forms, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_forms/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_metric_events, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_metric_events/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=ticket_metrics, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/ticket_metrics/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=tickets, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/tickets/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):85 - Write config: WriteConfig{streamName=users, namespace=null, outputBucketPath=zendesk/, pathFormat=zendesk//${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_, fullOutputPath=zendesk/users/2022_04_25_1650898082886_, syncMode=append} 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):92 - Preparing bucket in destination started for 8 streams 2022-04-25 14:48:05 destination > 2022-04-25 14:48:03 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):112 - Preparing storage area in destination completed. 2022-04-25 14:48:05 source > Starting syncing SourceZendeskSupport 2022-04-25 14:48:05 source > Syncing stream: ticket_audits 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream ticket_audits (current state: 0 bytes in 0 buffers) 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):129 - Schema name "events.items" contains illegal character(s) and is standardized to "events_items" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):129 - Schema name "attachments.items" contains illegal character(s) and is standardized to "attachments_items" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):129 - Schema name "thumbnails.items" contains illegal character(s) and is standardized to "thumbnails_items" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):168 - Field name "2" contains illegal character(s) and is standardized to "_2" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):129 - Schema name "2" contains illegal character(s) and is standardized to "_2" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):168 - Field name "11" contains illegal character(s) and is standardized to "_11" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(getAvroSchema):129 - Schema name "11" contains illegal character(s) and is standardized to "_11" 2022-04-25 14:48:13 destination > 2022-04-25 14:48:13 WARN o.a.h.u.NativeCodeLoader():60 - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2022-04-25 14:48:14 destination > 2022-04-25 14:48:14 ERROR i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):52 - Exception while accepting message 2022-04-25 14:48:14 destination > tech.allegro.schema.json2avro.converter.AvroConversionException: Failed to convert JSON to Avro: Could not evaluate union, field events is expected to be one of these: NULL, ARRAY. If this is a complex type, check if offending field: events.previous_value adheres to schema. 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:129) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:118) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonAvroConverter.convertToGenericDataRecord(JsonAvroConverter.java:95) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.s3.avro.AvroRecordFactory.getAvroRecord(AvroRecordFactory.java:39) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.accept(ParquetSerializedBuffer.java:93) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:69) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.gcs.GcsDestination.main(GcsDestination.java:39) [io.airbyte.airbyte-integrations.connectors-destination-gcs-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > Caused by: org.apache.avro.AvroTypeException: Could not evaluate union, field events is expected to be one of these: NULL, ARRAY. If this is a complex type, check if offending field: events.previous_value adheres to schema. 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.AvroTypeExceptions.unionException(AvroTypeExceptions.java:28) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readUnion(JsonGenericRecordReader.java:289) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:196) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:170) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.lambda$readRecord$0(JsonGenericRecordReader.java:152) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at java.util.LinkedHashMap.forEach(LinkedHashMap.java:721) ~[?:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readRecord(JsonGenericRecordReader.java:141) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:127) ~[converter-0.2.11-SNAPSHOT.jar:?] 2022-04-25 14:48:14 destination > ... 17 more 2022-04-25 14:48:14 destination > 2022-04-25 14:48:14 WARN i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: failed. 2022-04-25 14:48:14 destination > 2022-04-25 14:48:14 ERROR i.a.i.d.b.BufferedStreamConsumer(close):168 - executing on failed close procedure. 2022-04-25 14:48:14 destination > 2022-04-25 14:48:14 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream ticket_audits 2022-04-25 14:48:14 destination > 2022-04-25 14:48:14 ERROR i.a.i.d.r.SerializedBufferingStrategy(close):123 - Exception while closing stream buffer 2022-04-25 14:48:14 destination > java.lang.NullPointerException: Cannot invoke "java.io.InputStream.close()" because "this.inputStream" is null 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.close(ParquetSerializedBuffer.java:154) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.close(SerializedBufferingStrategy.java:120) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:173) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:162) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.gcs.GcsDestination.main(GcsDestination.java:39) [io.airbyte.airbyte-integrations.connectors-destination-gcs-0.36.2-alpha.jar:?] 2022-04-25 14:48:14 destination > Exception in thread "main" tech.allegro.schema.json2avro.converter.AvroConversionException: Failed to convert JSON to Avro: Could not evaluate union, field events is expected to be one of these: NULL, ARRAY. If this is a complex type, check if offending field: events.previous_value adheres to schema. 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:129) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:118) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonAvroConverter.convertToGenericDataRecord(JsonAvroConverter.java:95) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.s3.avro.AvroRecordFactory.getAvroRecord(AvroRecordFactory.java:39) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.accept(ParquetSerializedBuffer.java:93) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:69) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.gcs.GcsDestination.main(GcsDestination.java:39) 2022-04-25 14:48:14 destination > Suppressed: java.lang.RuntimeException: Exceptions thrown while closing buffers: java.lang.NullPointerException: Cannot invoke "java.io.InputStream.close()" because "this.inputStream" is null 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.close(SerializedBufferingStrategy.java:127) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:173) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67) 2022-04-25 14:48:14 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:162) 2022-04-25 14:48:14 destination > ... 2 more 2022-04-25 14:48:14 destination > Caused by: org.apache.avro.AvroTypeException: Could not evaluate union, field events is expected to be one of these: NULL, ARRAY. If this is a complex type, check if offending field: events.previous_value adheres to schema. 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.AvroTypeExceptions.unionException(AvroTypeExceptions.java:28) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readUnion(JsonGenericRecordReader.java:289) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:196) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:170) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.lambda$readRecord$0(JsonGenericRecordReader.java:152) 2022-04-25 14:48:14 destination > at java.base/java.util.LinkedHashMap.forEach(LinkedHashMap.java:721) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readRecord(JsonGenericRecordReader.java:141) 2022-04-25 14:48:14 destination > at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:127) 2022-04-25 14:48:14 destination > ... 17 more 2022-04-25 14:49:14 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 2022-04-25 14:49:14 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.format_type: does not have a value in the enumeration [Avro], $.compression_codec: string found, object expected, $.compression_codec: should be valid to one and only one of the schemas 2022-04-25 14:49:14 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.format_type: does not have a value in the enumeration [CSV] 2022-04-25 14:49:14 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.format_type: does not have a value in the enumeration [JSONL] 2022-04-25 14:49:14 INFO i.a.w.p.KubePodProcess(destroy):655 - (pod: airbyte / source-zendesk-support-sync-15-1-nbjao) - Destroying Kube process. 2022-04-25 14:49:14 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Socket closed. Typically happens when cancelling a job. 2022-04-25 14:49:14 INFO i.a.w.p.KubePodProcess(close):710 - (pod: airbyte / source-zendesk-support-sync-15-1-nbjao) - Closed all resources for pod 2022-04-25 14:49:14 INFO i.a.w.p.KubePodProcess(destroy):661 - (pod: airbyte / source-zendesk-support-sync-15-1-nbjao) - Destroyed Kube process. 2022-04-25 14:49:14 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: java.net.SocketException: Socket closed at sun.nio.ch.NioSocketImpl.ensureOpenAndConnected(NioSocketImpl.java:165) ~[?:?] at sun.nio.ch.NioSocketImpl.beginWrite(NioSocketImpl.java:366) ~[?:?] at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:411) ~[?:?] at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) ~[?:?] at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) ~[?:?] at java.net.Socket$SocketOutputStream.write(Socket.java:1035) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296) ~[io.airbyte-airbyte-workers-0.36.2-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.net.SocketException: Broken pipe at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:420) ~[?:?] at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) ~[?:?] at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) ~[?:?] at java.net.Socket$SocketOutputStream.write(Socket.java:1035) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) ~[?:?] at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) ~[?:?] at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) ~[?:?] at java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) ~[?:?] at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) ~[?:?] at java.io.BufferedWriter.write(BufferedWriter.java:233) ~[?:?] at java.io.Writer.write(Writer.java:249) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) ~[io.airbyte-airbyte-workers-0.36.2-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294) ~[io.airbyte-airbyte-workers-0.36.2-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-25 14:49:14 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@789dae2e[status=failed,recordsSynced=408,bytesSynced=1838953,startTime=1650898078637,endTime=1650898154514,totalStats=io.airbyte.config.SyncStats@6bbece99[recordsEmitted=408,bytesEmitted=1838953,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@5f3c32b4[streamName=ticket_audits,stats=io.airbyte.config.SyncStats@7e087e30[recordsEmitted=408,bytesEmitted=1838953,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-25 14:49:14 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-25 14:49:14 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@14fd152e[state={}] 2022-04-25 14:49:14 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-25 14:49:14 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@294f1c4d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6d278f59[status=failed,recordsSynced=408,bytesSynced=1838953,startTime=1650898078637,endTime=1650898154514,totalStats=io.airbyte.config.SyncStats@6bbece99[recordsEmitted=408,bytesEmitted=1838953,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@5f3c32b4[streamName=ticket_audits,stats=io.airbyte.config.SyncStats@7e087e30[recordsEmitted=408,bytesEmitted=1838953,stateMessagesEmitted=,recordsCommitted=]]]],normalizationSummary=,state=io.airbyte.config.State@14fd152e[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7cb8cfd5[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@7fe355b3[stream=io.airbyte.protocol.models.AirbyteStream@2e9f9376[name=ticket_audits,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"via":{"type":["null","object"],"properties":{"source":{"type":["null","object"],"properties":{"to":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"address":{"type":["null","string"]}}},"rel":{"type":["null","string"]},"from":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"title":{"type":["null","string"]},"address":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"subject":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"ticket_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"original_recipients":{"type":["null","array"],"items":{"type":["null","string"]}}}}}},"channel":{"type":["null","string"]}}},"events":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"via":{"type":["null","object"],"properties":{"source":{"type":["null","object"],"properties":{"to":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"address":{"type":["null","string"]}}},"rel":{"type":["null","string"]},"from":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"title":{"type":["null","string"]},"address":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"subject":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"revision_id":{"type":["null","integer"]},"original_recipients":{"type":["null","array"],"items":{"type":["null","string"]}}}}}},"channel":{"type":["null","string"]}}},"body":{"type":["null","string"]},"data":{"type":["null","object"],"properties":{"to":{"type":["null","string"]},"from":{"type":["null","string"]},"started_at":{"type":["null","string"],"format":"date-time"},"call_duration":{"type":["null","string"]},"recording_url":{"type":["null","string"]},"answered_by_id":{"type":["null","integer"]},"answered_by_name":{"type":["null","string"]},"transcription_text":{"type":["null","string"]},"transcription_status":{"type":["null","string"]}}},"type":{"type":["null","string"]},"value":{"type":["null","string","array"],"items":{"type":["null","string"]}},"public":{"type":["null","boolean"]},"subject":{"type":["null","string"]},"trusted":{"type":["null","boolean"]},"audit_id":{"type":["null","integer"]},"macro_id":{"type":["null","string"]},"resource":{"type":["null","string"]},"author_id":{"type":["null","integer"]},"html_body":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"field_name":{"type":["null","string"]},"plain_body":{"type":["null","string"]},"recipients":{"type":["null","array"],"items":{"type":["null","integer"]}},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"thumbnails":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}}},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}}},"macro_title":{"type":["null","string"]},"formatted_to":{"type":["null","string"]},"macro_deleted":{"type":["null","boolean"]},"formatted_from":{"type":["null","string"]},"previous_value":{"type":["null","string"]},"transcription_visible":{"type":["null","boolean"]}}}},"metadata":{"type":["null","object"],"properties":{"flags":{"type":["null","array"],"items":{"type":["null","integer"]}},"custom":{"type":["null","object"]},"system":{"type":["null","object"],"properties":{"client":{"type":["null","string"]},"latitude":{"type":["null","number"]},"location":{"type":["null","string"]},"longitude":{"type":["null","number"]},"ip_address":{"type":["null","string"]},"message_id":{"type":["null","string"]},"raw_email_identifier":{"type":["null","string"]},"json_email_identifier":{"type":["null","string"]}}},"trusted":{"type":["null","boolean"]},"flags_options":{"type":["null","object"],"properties":{"2":{"type":["null","object"],"properties":{"trusted":{"type":["null","boolean"]}}},"11":{"type":["null","object"],"properties":{"message":{"type":["null","object"],"properties":{"user":{"type":["null","string"]}}},"trusted":{"type":["null","boolean"]}}}}},"notifications_suppressed_for":{"type":["null","array"],"items":{"type":["null","integer"]}}}},"author_id":{"type":["null","integer"]},"ticket_id":{"type":["null","integer"]},"created_at":{"type":["null","string"],"format":"date-time"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[created_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[created_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7f938cbb[stream=io.airbyte.protocol.models.AirbyteStream@456f22fb[name=ticket_comments,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"via":{"type":["null","object"],"properties":{"source":{"type":["null","object"],"properties":{"to":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"address":{"type":["null","string"]}}},"rel":{"type":["null","string"]},"from":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"title":{"type":["null","string"]},"address":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"subject":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"ticket_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"original_recipients":{"type":["null","array"],"items":{"type":["null","string"]}}}}}},"channel":{"type":["null","string"]}}},"body":{"type":["null","string"]},"type":{"type":["null","string"]},"public":{"type":["null","boolean"]},"audit_id":{"type":["null","integer"]},"metadata":{"type":["null","object"],"properties":{"flags":{"type":["null","array"],"items":{"type":["null","integer"]}},"custom":{"type":["null","object"]},"system":{"type":["null","object"],"properties":{"client":{"type":["null","string"]},"latitude":{"type":["null","number"]},"location":{"type":["null","string"]},"longitude":{"type":["null","number"]},"ip_address":{"type":["null","string"]},"message_id":{"type":["null","string"]},"raw_email_identifier":{"type":["null","string"]},"json_email_identifier":{"type":["null","string"]}}},"trusted":{"type":["null","boolean"]},"flags_options":{"type":["null","object"],"properties":{"2":{"type":["null","object"],"properties":{"trusted":{"type":["null","boolean"]}}},"11":{"type":["null","object"],"properties":{"message":{"type":["null","object"],"properties":{"user":{"type":["null","string"]}}},"trusted":{"type":["null","boolean"]}}}}},"notifications_suppressed_for":{"type":["null","array"],"items":{"type":["null","integer"]}}}},"author_id":{"type":["null","integer"]},"html_body":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"timestamp":{"type":["null","integer"]},"created_at":{"type":["null","string"],"format":"date-time"},"plain_body":{"type":["null","string"]},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"thumbnails":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}}},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}}},"via_reference_id":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[created_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[created_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@20c4a928[stream=io.airbyte.protocol.models.AirbyteStream@72129a65[name=ticket_fields,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"tag":{"type":["null","string"]},"url":{"type":["null","string"]},"type":{"type":["null","string"]},"title":{"type":["null","string"]},"active":{"type":["null","boolean"]},"position":{"type":["null","integer"]},"required":{"type":["null","boolean"]},"raw_title":{"type":["null","string"]},"removable":{"type":["null","boolean"]},"created_at":{"type":["null","string"],"format":"date-time"},"updated_at":{"type":["null","string"],"format":"date-time"},"description":{"type":["null","string"]},"sub_type_id":{"type":["null","integer"]},"raw_description":{"type":["null","string"]},"title_in_portal":{"type":["null","string"]},"agent_description":{"type":["null","string"]},"visible_in_portal":{"type":["null","boolean"]},"editable_in_portal":{"type":["null","boolean"]},"required_in_portal":{"type":["null","boolean"]},"raw_title_in_portal":{"type":["null","string"]},"collapsed_for_agents":{"type":["null","boolean"]},"custom_field_options":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"value":{"type":["null","string"]},"default":{"type":["null","boolean"]},"raw_name":{"type":["null","string"]}}}},"system_field_options":{"type":["null","array"]},"regexp_for_validation":{"type":["null","string"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@110736c8[stream=io.airbyte.protocol.models.AirbyteStream@2d43a6e9[name=ticket_forms,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"default":{"type":["null","boolean"]},"position":{"type":["null","integer"]},"raw_name":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"updated_at":{"type":["null","string"],"format":"date-time"},"display_name":{"type":["null","string"]},"in_all_brands":{"type":["null","boolean"]},"end_user_visible":{"type":["null","boolean"]},"raw_display_name":{"type":["null","string"]},"ticket_field_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"restricted_brand_ids":{"type":["null","array"],"items":{"type":["null","integer"]}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@284bd780[stream=io.airbyte.protocol.models.AirbyteStream@4e6ca15e[name=ticket_metric_events,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"time":{"type":["null","string"]},"type":{"type":["null","string"]},"metric":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"instance_id":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[time],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[time],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@66757f2d[stream=io.airbyte.protocol.models.AirbyteStream@56b1e9e4[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=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2030d365[stream=io.airbyte.protocol.models.AirbyteStream@bfdf06c[name=tickets,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"via":{"type":["null","object"],"properties":{"source":{"type":["null","object"],"properties":{"to":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"phone":{"type":["null","string"]},"address":{"type":["null","string"]},"username":{"type":["null","string"]},"email_ccs":{"type":["null","string"]},"facebook_id":{"type":["null","string"]},"profile_url":{"type":["null","string"]},"formatted_phone":{"type":["null","string"]}}},"rel":{"type":["null","string"]},"from":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"phone":{"type":["null","string"]},"title":{"type":["null","string"]},"address":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"subject":{"type":["null","string"]},"topic_id":{"type":["null","integer"]},"username":{"type":["null","string"]},"ticket_id":{"type":["null","integer"]},"topic_name":{"type":["null","string"]},"facebook_id":{"type":["null","string"]},"profile_url":{"type":["null","string"]},"revision_id":{"type":["null","integer"]},"formatted_phone":{"type":["null","string"]},"original_recipients":{"type":["null","array"],"items":{"type":["null","string"]}}}}}},"channel":{"type":["null","string"]}}},"tags":{"type":["null","array"],"items":{"type":["null","string"]}},"type":{"type":["null","string"]},"due_at":{"type":["null","string"],"format":"date-time"},"status":{"type":["null","string"]},"subject":{"type":["null","string"]},"brand_id":{"type":["null","integer"]},"group_id":{"type":["null","integer"]},"priority":{"type":["null","string"]},"is_public":{"type":["null","boolean"]},"recipient":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"problem_id":{"type":["null","integer"]},"updated_at":{"type":["null","string"],"format":"date-time"},"assignee_id":{"type":["null","integer"]},"description":{"type":["null","string"]},"external_id":{"type":["null","string"]},"raw_subject":{"type":["null","string"]},"email_cc_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"follower_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"followup_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"requester_id":{"type":["null","integer"]},"submitter_id":{"type":["null","integer"]},"custom_fields":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"value":{"type":["null","string"]}}}},"has_incidents":{"type":["null","boolean"]},"forum_topic_id":{"type":["null","integer"]},"ticket_form_id":{"type":["null","integer"]},"organization_id":{"type":["null","integer"]},"collaborator_ids":{"type":["null","array"],"items":{"type":["null","integer"]}},"allow_attachments":{"type":["null","boolean"]},"allow_channelback":{"type":["null","boolean"]},"generated_timestamp":{"type":["null","integer"]},"satisfaction_rating":{"type":["null","object","string"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"score":{"type":["null","string"]},"reason":{"type":["null","string"]},"comment":{"type":["null","string"]},"group_id":{"type":["null","integer"]},"reason_id":{"type":["null","integer"]},"ticket_id":{"type":["null","integer"]},"created_at":{"type":["null","string"],"format":"date-time"},"updated_at":{"type":["null","string"],"format":"date-time"},"assignee_id":{"type":["null","integer"]},"requester_id":{"type":["null","integer"]}}},"sharing_agreement_ids":{"type":["null","array"],"items":{"type":["null","integer"]}}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@46bc6a29[stream=io.airbyte.protocol.models.AirbyteStream@1f1b45d3[name=users,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"name":{"type":["null","string"]},"role":{"type":["null","string"]},"tags":{"type":["null","array"],"items":{"type":["null","string"]}},"alias":{"type":["null","string"]},"email":{"type":["null","string"]},"notes":{"type":["null","string"]},"phone":{"type":["null","string"]},"photo":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"thumbnails":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"url":{"type":["null","string"]},"size":{"type":["null","integer"]},"width":{"type":["null","integer"]},"height":{"type":["null","integer"]},"inline":{"type":["null","boolean"]},"file_name":{"type":["null","string"]},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}}},"content_url":{"type":["null","string"]},"content_type":{"type":["null","string"]},"mapped_content_url":{"type":["null","string"]}}},"active":{"type":["null","boolean"]},"locale":{"type":["null","string"]},"shared":{"type":["null","boolean"]},"details":{"type":["null","string"]},"verified":{"type":["null","boolean"]},"chat_only":{"type":["null","boolean"]},"locale_id":{"type":["null","integer"]},"moderator":{"type":["null","boolean"]},"role_type":{"type":["null","integer"]},"signature":{"type":["null","string"]},"suspended":{"type":["null","boolean"]},"time_zone":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"report_csv":{"type":["null","boolean"]},"updated_at":{"type":["null","string"],"format":"date-time"},"external_id":{"type":["null","string"]},"user_fields":{"type":["null","object"],"additionalProperties":true},"shared_agent":{"type":["null","boolean"]},"last_login_at":{"type":["null","string"],"format":"date-time"},"custom_role_id":{"type":["null","integer"]},"organization_id":{"type":["null","integer"]},"default_group_id":{"type":["null","integer"]},"restricted_agent":{"type":["null","boolean"]},"ticket_restriction":{"type":["null","string"]},"permanently_deleted":{"type":["null","boolean"]},"shared_phone_number":{"type":["null","boolean"]},"only_private_comments":{"type":["null","boolean"]},"two_factor_auth_enabled":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@399606ae[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@5d0cff60[additionalProperties={attemptNumber=1, jobId=15}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed 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 message delivery failed at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: java.net.SocketException: Broken pipe at java.base/sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:420) at java.base/sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) at java.base/sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) at java.base/java.net.Socket$SocketOutputStream.write(Socket.java:1035) at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233) at java.base/java.io.Writer.write(Writer.java:249) at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294) ... 4 more ,retryable=,timestamp=1650898094501], io.airbyte.config.FailureReason@78c43bca[failureOrigin=destination,failureType=,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@3db4dcdc[additionalProperties={attemptNumber=1, jobId=15}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1650898095236]]] 2022-04-25 14:49:14 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-25 14:49:14 INFO i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection 6c782d2d-1178-420f-9d6a-d0bf6b4432b1 state: io.airbyte.config.State@4a74827b[state={}]