2022-01-13 05:10:20 INFO () WorkerRun(call):42 - Executing worker wrapper. Airbyte version: 0.30.18-alpha 2022-01-13 05:10:20 INFO () TemporalAttemptExecution(get):94 - Executing worker wrapper. Airbyte version: 0.30.18-alpha 2022-01-13 05:10:20 WARN () Databases(createPostgresDatabaseWithRetry):38 - Waiting for database to become available... 2022-01-13 05:10:20 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-01-13 05:10:20 INFO () Databases(createPostgresDatabaseWithRetry):55 - Database available! 2022-01-13 05:10:20 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 9467 attempt id: 0 2022-01-13 05:10:20 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:20 INFO () DefaultAirbyteDestination(start):58 - Running destination... 2022-01-13 05:10:20 INFO () LineGobbler(voidCall):65 - Checking if airbyte/destination-s3:0.2.0 exists... 2022-01-13 05:10:20 INFO () LineGobbler(voidCall):65 - airbyte/destination-s3:0.2.0 was found locally. 2022-01-13 05:10:20 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/9467/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:20 INFO () LineGobbler(voidCall):65 - Checking if airbyte/source-delighted:0.1.2 exists... 2022-01-13 05:10:20 INFO () LineGobbler(voidCall):65 - airbyte/source-delighted:0.1.2 was found locally. 2022-01-13 05:10:20 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/9467/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:20 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started. 2022-01-13 05:10:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started. 2022-01-13 05:10:20 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join. 2022-01-13 05:10:21 ERROR () LineGobbler(voidCall):65 - SLF4J: Class path contains multiple SLF4J bindings. 2022-01-13 05:10:21 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:21 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:21 ERROR () LineGobbler(voidCall):65 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-01-13 05:10:21 ERROR () LineGobbler(voidCall):65 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Starting syncing SourceDelighted 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: bounces 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of bounces stream to {'bounced_at': 1632420528} 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of bounces stream to {'bounced_at': 1632420528} 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from bounces stream 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: people 2022-01-13 05:10:21 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 INFO i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.destination.s3.S3Destination 2022-01-13 05:10:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 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:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 INFO i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE 2022-01-13 05:10:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 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:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 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:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 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:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:22 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - {} - S3 format config: {"format_type":"JSONL","part_size_mb":5} 2022-01-13 05:10:22 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'bounces': s3://*-data-lake-landing/delighted/bounces/2022_01_13_1642050623007_0.jsonl 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of people stream to {'created_at': 1614731699} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 136 records from people stream 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: survey_responses 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of survey_responses stream to {'updated_at': 1616167778} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/bounces/2022_01_13_1642050623007_0.jsonl with full ID EyApJDMma320HSVLux3OKPC7VgT3KnnVM3xtLt0QNaHjSyAF9aU9kumekrWl7hAYDHM6U551AlHAx8zZ4Q.H7MuxdsO_aqUk6crWcWwAUaqiOLZvsShxm0VbChLmytir 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'people': s3://*-data-lake-landing/delighted/people/2022_01_13_1642050623007_0.jsonl 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/people/2022_01_13_1642050623007_0.jsonl with full ID X6ognXxYNngDvSDie.1WhQU5iiAoSByUnAmi_hs0Bon8YGH_VxAdQgrpnbW8VbFkLrsR3xmlX0QYd7m1BINC.dLRcyfgR7JJ9Nfy4qT6w90vF4IjscDjVV7gzUgTlZRM 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of survey_responses stream to {'updated_at': 1616167778} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from survey_responses stream 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing stream: unsubscribes 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of unsubscribes stream to {'unsubscribed_at': 1614783627} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 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_1642050623007_0.jsonl 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050623007_0.jsonl with full ID 2g4DiBjhsvye74JC1PBAQFIPbGJZVm96SO6MeugYFwlTHHqoL.gGIloLqYm.9p56GXSmdTcrYeItJNW1cNrBvzoDMsfM8TkleQfVrL_NY8Jxgvf6ZvI_wAqNbeCR0hi_ 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.j.S3JsonlWriter():51 - {} - Full S3 path for stream 'unsubscribes': s3://*-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050623007_0.jsonl 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - {} - PartSize arg is set to 5 MB 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:23 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050623007_0.jsonl with full ID WT2UFowxJLyuLJi_ukTn5RkLzgbAkXi6tZpDi8UAkcTnKTZr.zWcdRDVHFklZY2XoRGNOQFEq.UPj1mcQRhb7nIIIy2clyAugTnu_HwwSWtk7dqvBNIB8.vvF5LiTxk1 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Setting state of unsubscribes stream to {'unsubscribed_at': 1614783627} 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Read 1 records from unsubscribes stream 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - SourceDelighted runtimes: 2022-01-13 05:10:23 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceDelighted 2022-01-13 05:10:24 INFO () DefaultReplicationWorker(run):121 - Source thread complete. 2022-01-13 05:10:24 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'unsubscribes'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050623007_0.jsonl with id WT2UFowxJ...vF5LiTxk1]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050623007_0.jsonl with id WT2UFowxJ...vF5LiTxk1]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/unsubscribes/2022_01_13_1642050623007_0.jsonl with id WT2UFowxJ...vF5LiTxk1]: Completed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'unsubscribes'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'bounces'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050623007_0.jsonl with id EyApJDMma...bChLmytir]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050623007_0.jsonl with id EyApJDMma...bChLmytir]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/bounces/2022_01_13_1642050623007_0.jsonl with id EyApJDMma...bChLmytir]: Completed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'bounces'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'people'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050623007_0.jsonl with id X6ognXxYN...gzUgTlZRM]: Uploading leftover stream [Part number 1 containing 0.04 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050623007_0.jsonl with id X6ognXxYN...gzUgTlZRM]: Finished uploading [Part number 1 containing 0.04 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/people/2022_01_13_1642050623007_0.jsonl with id X6ognXxYN...gzUgTlZRM]: Completed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'people'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):107 - {} - Uploading remaining data for stream 'survey_responses'. 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 WARN a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050623007_0.jsonl with id 2g4DiBjhs...NbeCR0hi_]: Uploading leftover stream [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050623007_0.jsonl with id 2g4DiBjhs...NbeCR0hi_]: Finished uploading [Part number 1 containing 0.00 MB] 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to *-data-lake-landing/delighted/survey_responses/2022_01_13_1642050623007_0.jsonl with id 2g4DiBjhs...NbeCR0hi_]: Completed 2022-01-13 05:10:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.d.s.w.BaseS3Writer(close):109 - {} - Upload completed for stream 'survey_responses'. 2022-01-13 05:10:24 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):231 - state in DefaultReplicationWorker from Destination: io.airbyte.protocol.models.AirbyteMessage@d525794[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@395a84e[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:24 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2022-01-13 05:10:24 INFO i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.destination.s3.S3Destination 2022-01-13 05:10:25 INFO () DefaultReplicationWorker(run):124 - Destination thread complete. 2022-01-13 05:10:25 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@403879[status=completed,recordsSynced=139,bytesSynced=26638,startTime=1642050620272,endTime=1642050625130] 2022-01-13 05:10:25 INFO () DefaultReplicationWorker(run):159 - Source output at least one state message 2022-01-13 05:10:25 INFO () DefaultReplicationWorker(run):165 - State capture: Updated state to: Optional[io.airbyte.config.State@74d7ad17[state={"people":{"created_at":1614731699},"bounces":{"bounced_at":1632420528},"unsubscribes":{"unsubscribed_at":1614783627},"survey_responses":{"updated_at":1616167778}}]] 2022-01-13 05:10:25 INFO () TemporalAttemptExecution(get):115 - Stopping cancellation check scheduling... 2022-01-13 05:10:25 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):177 - sync summary: io.airbyte.config.StandardSyncOutput@34b5c612[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5c3c5f50[status=completed,recordsSynced=139,bytesSynced=26638,startTime=1642050620272,endTime=1642050625130],state=io.airbyte.config.State@74d7ad17[state={"people":{"created_at":1614731699},"bounces":{"bounced_at":1632420528},"unsubscribes":{"unsubscribed_at":1614783627},"survey_responses":{"updated_at":1616167778}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@193af7ca[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2ae4481e[stream=io.airbyte.protocol.models.AirbyteStream@30fb9e06[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@e839196[stream=io.airbyte.protocol.models.AirbyteStream@40c9b32b[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@4865b794[stream=io.airbyte.protocol.models.AirbyteStream@24020b30[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@361f3107[stream=io.airbyte.protocol.models.AirbyteStream@3bc29c04[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={}]]