2022-01-13 05:10:30 INFO () WorkerRun(call):42 - Executing worker wrapper. Airbyte version: 0.30.18-alpha 2022-01-13 05:10:30 INFO () TemporalAttemptExecution(get):94 - Executing worker wrapper. Airbyte version: 0.30.18-alpha 2022-01-13 05:10:30 WARN () Databases(createPostgresDatabaseWithRetry):38 - Waiting for database to become available... 2022-01-13 05:10:30 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-01-13 05:10:30 INFO () Databases(createPostgresDatabaseWithRetry):55 - Database available! 2022-01-13 05:10:30 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 9468 attempt id: 0 2022-01-13 05:10:30 INFO () DefaultReplicationWorker(run):91 - configured sync modes: {null.survey_responses=incremental - append, null.people=incremental - append, null.bounces=incremental - append, null.unsubscribes=incremental - append} 2022-01-13 05:10:30 INFO () DefaultAirbyteDestination(start):58 - Running destination... 2022-01-13 05:10:30 INFO () LineGobbler(voidCall):65 - Checking if airbyte/destination-s3:0.2.0 exists... 2022-01-13 05:10:30 INFO () LineGobbler(voidCall):65 - airbyte/destination-s3:0.2.0 was found locally. 2022-01-13 05:10:30 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/9468/0 --network host --log-driver none airbyte/destination-s3:0.2.0 write --config destination_config.json --catalog destination_catalog.json 2022-01-13 05:10:30 INFO () LineGobbler(voidCall):65 - Checking if airbyte/source-delighted:0.1.2 exists... 2022-01-13 05:10:30 INFO () LineGobbler(voidCall):65 - airbyte/source-delighted:0.1.2 was found locally. 2022-01-13 05:10:30 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/9468/0 --network host --log-driver none airbyte/source-delighted:0.1.2 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-01-13 05:10:30 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started. 2022-01-13 05:10:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started. 2022-01-13 05:10:30 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join. 2022-01-13 05:10:31 ERROR () LineGobbler(voidCall):65 - SLF4J: Class path contains multiple SLF4J bindings. 2022-01-13 05:10:31 ERROR () LineGobbler(voidCall):65 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.16.0.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-01-13 05:10:31 ERROR () LineGobbler(voidCall):65 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-01-13 05:10:31 ERROR () LineGobbler(voidCall):65 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Starting syncing SourceDelighted 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: bounces 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of bounces stream to {'bounced_at': 1632420528} 2022-01-13 05:10:31 ERROR () LineGobbler(voidCall):65 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of bounces stream to {'bounced_at': 1632420528} 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from bounces stream 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: people 2022-01-13 05:10:31 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.destination.s3.S3Destination 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.b.IntegrationRunner(run):81 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 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-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 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-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - {} - S3 format config: {"format_type":"JSONL","part_size_mb":5} 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'bounces': s3://*-data-lake-landing/delighted/bounces/2022_01_13_1642050632964_0.jsonl 2022-01-13 05:10:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:32 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 136 records from people stream 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: survey_responses 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of survey_responses stream to {'updated_at': 1616167778} 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/bounces/2022_01_13_1642050632964_0.jsonl with full ID rKwz3ej.amWCCBwSbPUeCmpT3XH6rPxEmh35uQz7gAorINPbPA9zfrrN._B8bLqxVyk9gGbpQLbzufo_vg_Hne36mtug68PpDL5QbRngHIdCwcbA3NXqt2Pdj_94i6HI 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'people': s3://*-data-lake-landing/delighted/people/2022_01_13_1642050632964_0.jsonl 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/people/2022_01_13_1642050632964_0.jsonl with full ID BD1tPcmYL_yNeb02IQdqYt2zq9uYexSneyXOMq.BcrXHMn61J.hOTvU9CvxszT1IFuA6cSqdIo1jFIKKUGYnG4DteZUsDgvnwc5EyQPpE2amgK6aYNhzCcPDi5OyeTYP 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'survey_responses': s3://*-data-lake-landing/delighted/survey_responses/2022_01_13_1642050632964_0.jsonl 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050632964_0.jsonl with full ID OPKSiqxYUXGS.jky9nnOYj1J.zxEyNmqGZ.Ee.MEHwPqyuJ5_4H_EuGEHjUfDyldPlXEdVBRIvy4YAXmZU4KT9HcoYDuqvbBVOCKMD8ViU4.PixMHV7AWx2whF5G7H03 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'unsubscribes': s3://*-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050632964_0.jsonl 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050632964_0.jsonl with full ID 9VJHoAdN276kAkUGs93SeE4JqdXA8UG390WMv1folf8QM0iIMkWjWyB1FkkUWRmVEnlJBKtpOD9bIhTDMVrWeS8NBY8hMTyBumaU8svF1ScziEk8NAjr4ZWEBeAqxV.H 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of survey_responses stream to {'updated_at': 1616167778} 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from survey_responses stream 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: unsubscribes 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of unsubscribes stream to {'unsubscribed_at': 1614783627} 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of unsubscribes stream to {'unsubscribed_at': 1614783627} 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from unsubscribes stream 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:33 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):121 - Source thread complete. 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'unsubscribes'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050632964_0.jsonl with id 9VJHoAdN2...EBeAqxV.H]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050632964_0.jsonl with id 9VJHoAdN2...EBeAqxV.H]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050632964_0.jsonl with id 9VJHoAdN2...EBeAqxV.H]: Completed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'unsubscribes'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'bounces'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050632964_0.jsonl with id rKwz3ej.a...dj_94i6HI]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050632964_0.jsonl with id rKwz3ej.a...dj_94i6HI]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050632964_0.jsonl with id rKwz3ej.a...dj_94i6HI]: Completed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'bounces'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'people'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050632964_0.jsonl with id BD1tPcmYL...Di5OyeTYP]: Uploading leftover stream [Part number 1 containing 0.04 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050632964_0.jsonl with id BD1tPcmYL...Di5OyeTYP]: Finished uploading [Part number 1 containing 0.04 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050632964_0.jsonl with id BD1tPcmYL...Di5OyeTYP]: Completed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'people'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'survey_responses'. 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050632964_0.jsonl with id OPKSiqxYU...whF5G7H03]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050632964_0.jsonl with id OPKSiqxYU...whF5G7H03]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050632964_0.jsonl with id OPKSiqxYU...whF5G7H03]: Completed 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'survey_responses'. 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):231 - state in DefaultReplicationWorker from Destination: io.airbyte.protocol.models.AirbyteMessage@23eee3bb[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2d2919b6[data={"people":{"created_at":1614731699},"bounces":{"bounced_at":1632420528},"unsubscribes":{"unsubscribed_at":1614783627},"survey_responses":{"updated_at":1616167778}},additionalProperties={}],additionalProperties={}] 2022-01-13 05:10:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:34 INFO i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.destination.s3.S3Destination 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):124 - Destination thread complete. 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@74042bcf[status=completed,recordsSynced=139,bytesSynced=26638,startTime=1642050630317,endTime=1642050634847] 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):159 - Source output at least one state message 2022-01-13 05:10:34 INFO () DefaultReplicationWorker(run):165 - State capture: Updated state to: Optional[io.airbyte.config.State@68698f13[state={"people":{"created_at":1614731699},"bounces":{"bounced_at":1632420528},"unsubscribes":{"unsubscribed_at":1614783627},"survey_responses":{"updated_at":1616167778}}]] 2022-01-13 05:10:34 INFO () TemporalAttemptExecution(get):115 - Stopping cancellation check scheduling... 2022-01-13 05:10:34 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):177 - sync summary: io.airbyte.config.StandardSyncOutput@3ce9988f[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6a3f941[status=completed,recordsSynced=139,bytesSynced=26638,startTime=1642050630317,endTime=1642050634847],state=io.airbyte.config.State@68698f13[state={"people":{"created_at":1614731699},"bounces":{"bounced_at":1632420528},"unsubscribes":{"unsubscribed_at":1614783627},"survey_responses":{"updated_at":1616167778}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@6bcdb82c[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@48fa14a7[stream=io.airbyte.protocol.models.AirbyteStream@38a7c0d7[name=bounces,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"name":{"type":"string"},"email":{"type":"string"},"person_id":{"type":"string"},"bounced_at":{"type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[bounced_at],sourceDefinedPrimaryKey=[[person_id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[bounced_at],destinationSyncMode=append,primaryKey=[[person_id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@21d74f73[stream=io.airbyte.protocol.models.AirbyteStream@275d8fbd[name=people,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":"string"},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"created_at":{"type":"integer"},"last_sent_at":{"type":["integer","null"]},"last_responded_at":{"type":["integer","null"]},"next_survey_scheduled_at":{"type":["integer","null"]}}},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@3f1af8dd[stream=io.airbyte.protocol.models.AirbyteStream@393d2691[name=survey_responses,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-04/schema#","required":["id","person","survey_type","score","comment","permalink","created_at","updated_at","person_properties","notes","tags","additional_answers"],"properties":{"id":{"type":"string"},"tags":{"type":"array","items":{}},"notes":{"type":"array","items":{}},"score":{"type":"integer"},"person":{"type":"string"},"comment":{"type":["null","string"]},"permalink":{"type":"string"},"created_at":{"type":"integer"},"updated_at":{"type":["null","integer"]},"survey_type":{"type":"string"},"person_properties":{"type":"object"},"additional_answers":{"type":["array","null"],"items":{"type":"object","required":["id","value","question"],"properties":{"id":{"type":"string"},"value":{"type":"object","required":["free_response","scale","select_one","select_many"],"properties":{"scale":{"type":["null","integer"]},"select_one":{"type":["object","null"],"properties":{"id":{"type":"string"},"text":{"type":"string"}}},"select_many":{"type":["array","null"],"items":{"type":"object","required":["id","text"],"properties":{"id":{"type":"string"},"text":{"type":"string"}}}},"free_response":{"type":["null","string"]}}},"question":{"type":"object","required":["id","type","text"],"properties":{"id":{"type":"string"},"text":{"type":"string"},"type":{"type":"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@228a4a12[stream=io.airbyte.protocol.models.AirbyteStream@69611999[name=unsubscribes,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"name":{"type":["null","string"]},"email":{"type":"string"},"person_id":{"type":"string"},"unsubscribed_at":{"type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[unsubscribed_at],sourceDefinedPrimaryKey=[[person_id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[unsubscribed_at],destinationSyncMode=append,primaryKey=[[person_id]],additionalProperties={}]],additionalProperties={}]]