2022-04-04 22:50:24 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.64-alpha
2022-04-04 22:50:25 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/15012/0/logs.log
2022-04-04 22:50:25 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.64-alpha
2022-04-04 22:50:25 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 15012 attempt id: 0
2022-04-04 22:50:25 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.survey_questions=full_refresh - overwrite, null.survey_responses=incremental - append, null.survey_pages=full_refresh - overwrite}
2022-04-04 22:50:25 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-04 22:50:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.24 exists...
2022-04-04 22:50:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.24 was found locally.
2022-04-04 22:50:25 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 15012
2022-04-04 22:50:25 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/15012/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.24 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=15012 airbyte/destination-snowflake:0.4.24 write --config destination_config.json --catalog destination_catalog.json
2022-04-04 22:50:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-surveymonkey:0.1.7 exists...
2022-04-04 22:50:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-surveymonkey:0.1.7 was found locally.
2022-04-04 22:50:25 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 15012
2022-04-04 22:50:25 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/15012/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-surveymonkey:0.1.7 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=15012 airbyte/source-surveymonkey:0.1.7 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-04 22:50:25 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-04 22:50:25 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-04 22:50:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-04 22:50:28 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-04 22:50:28 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 22:50:28 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 22:50:28 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-04 22:50:28 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-04 22:50:28 source > Starting syncing SourceSurveymonkey
2022-04-04 22:50:28 source > Syncing stream: survey_pages
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 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-04 22:50:29 destination > 2022-04-04 22:50:29 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-04 22:50:29 destination > 2022-04-04 22:50:29 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-04 22:50:29 destination > 2022-04-04 22:50:29 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-04 22:50:29 destination > 2022-04-04 22:50:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 WARN i.a.i.d.s.SnowflakeDatabase(createDataSource):96 - Obsolete User/password login mode is used. Please re-create a connection to use the latest connector's version
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=survey_pages, namespace=survey_monkey, outputSchemaName=survey_monkey, tmpTableName=_airbyte_tmp_fhe_survey_pages, outputTableName=_airbyte_raw_survey_pages, syncMode=overwrite}
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=survey_questions, namespace=survey_monkey, outputSchemaName=survey_monkey, tmpTableName=_airbyte_tmp_xfo_survey_questions, outputTableName=_airbyte_raw_survey_questions, syncMode=overwrite}
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=survey_responses, namespace=survey_monkey, outputSchemaName=survey_monkey, tmpTableName=_airbyte_tmp_ded_survey_responses, outputTableName=_airbyte_raw_survey_responses, syncMode=append}
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 3 streams
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema survey_monkey stream survey_pages: tmp table: _airbyte_tmp_fhe_survey_pages, stage: SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/
2022-04-04 22:50:29 destination > 2022-04-04 22:50:29 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-04-04 22:50:30 source > Read 1 records from survey_pages stream
2022-04-04 22:50:30 source > Finished syncing survey_pages
2022-04-04 22:50:30 source > SourceSurveymonkey runtimes:
Syncing stream survey_pages 0:00:01.492597
2022-04-04 22:50:30 source > Syncing stream: survey_questions
2022-04-04 22:50:31 source > Read 11 records from survey_questions stream
2022-04-04 22:50:31 source > Finished syncing survey_questions
2022-04-04 22:50:31 source > SourceSurveymonkey runtimes:
Syncing stream survey_pages 0:00:01.492597
Syncing stream survey_questions 0:00:01.129775
2022-04-04 22:50:31 source > Syncing stream: survey_responses
2022-04-04 22:50:31 destination > 2022-04-04 22:50:31 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@66e21568
2022-04-04 22:50:31 destination > 2022-04-04 22:50:31 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-04-04 22:50:31 destination > 2022-04-04 22:50:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-04 22:50:31 source > Read 1 records from survey_responses stream
2022-04-04 22:50:31 source > Finished syncing survey_responses
2022-04-04 22:50:31 source > SourceSurveymonkey runtimes:
Syncing stream survey_pages 0:00:01.492597
Syncing stream survey_questions 0:00:01.129775
Syncing stream survey_responses 0:00:00.573921
2022-04-04 22:50:31 source > Finished syncing SourceSurveymonkey
2022-04-04 22:50:32 destination > 2022-04-04 22:50:32 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):72 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_PAGES does not exist in bucket; creating...
2022-04-04 22:50:32 destination > 2022-04-04 22:50:32 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):74 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_PAGES has been created in bucket.
2022-04-04 22:50:32 destination > 2022-04-04 22:50:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema survey_monkey stream survey_pages
2022-04-04 22:50:32 destination > 2022-04-04 22:50:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema survey_monkey stream survey_questions: tmp table: _airbyte_tmp_xfo_survey_questions, stage: SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/
2022-04-04 22:50:32 destination > 2022-04-04 22:50:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-04 22:50:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 14 (12 KB)
2022-04-04 22:50:33 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):72 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS does not exist in bucket; creating...
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):74 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS has been created in bucket.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema survey_monkey stream survey_questions
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema survey_monkey stream survey_responses: tmp table: _airbyte_tmp_ded_survey_responses, stage: SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):72 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES does not exist in bucket; creating...
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):74 - Storage Object my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES has been created in bucket.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema survey_monkey stream survey_responses
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream survey_pages (current state: 0 bytes in 0 buffers)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream survey_questions (current state: 0 bytes in 1 buffers)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream survey_responses (current state: 0 bytes in 2 buffers)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-04-04 22:50:33 destination > Ideally, this situation should not happen...
2022-04-04 22:50:33 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-04-04 22:50:33 destination > The main thread is: main (RUNNABLE)
2022-04-04 22:50:33 destination >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-04 22:50:33 destination >         at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-4-thread-1 (TIMED_WAITING)
2022-04-04 22:50:33 destination >  Thread stacktrace: java.base@17.0.1/jdk.internal.misc.Unsafe.park(Native Method)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:252)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1672)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:460)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1061)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1122)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-04 22:50:33 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 3 current buffers (0 bytes in total)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream survey_pages (10 bytes)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream survey_pages (10 bytes) to staging
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz (189 bytes)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to my-bucket/SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz with full ID K1Bzwnm7JYFLZqKW20Dma8ykW3NLMI_AQWQX5Pv4KU.J_kvj8SQmQP13q_w9ThGJ3HGFd72Ru067cHoUwaD1U2YXUCAswvKAiqK0ksxUGn1AJQJAkdlSZXZpZTBgQAI9
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz with id K1Bzwnm7J...pZTBgQAI9]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz with id K1Bzwnm7J...pZTBgQAI9]: Finished uploading [Part number 1 containing 0.00 MB]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz with id K1Bzwnm7J...pZTBgQAI9]: Completed
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream survey_responses (10 bytes)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream survey_responses (10 bytes) to staging
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz (786 bytes)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz with full ID OstlVYEMeTptGhTra1fLWw5ico8QwWbIK1_90bjdrtL3X2Y_GbkHDWJ3ZzNn9HKXHk3btWxeJ6zth7mkGGxNTovGaUbOmRQd38htd19n4JUOw3l7yBfRevYLg35o_1px
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz with id OstlVYEMe...Lg35o_1px]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz with id OstlVYEMe...Lg35o_1px]: Finished uploading [Part number 1 containing 0.00 MB]
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz with id OstlVYEMe...Lg35o_1px]: Completed
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream survey_questions (10 bytes)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream survey_questions (10 bytes) to staging
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz (2 KB)
2022-04-04 22:50:33 destination > 2022-04-04 22:50:33 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz with full ID IiQGgzM7Yz3m5Hbm3pIDG1_WqRl9tbg9PnNMgEHv.ZfVgIVDhwwCediIt09ZSJ_caDjBK5crSHnwP6Gxdy1tVu_HsW4fBmoxbl5cp02PCwiF1fcLeVIvp3TndeEubqNZ
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz with id IiQGgzM7Y...ndeEubqNZ]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz with id IiQGgzM7Y...ndeEubqNZ]: Finished uploading [Part number 1 containing 0.00 MB]
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to my-bucket/SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz with id IiQGgzM7Y...ndeEubqNZ]: Completed
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream survey_pages
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream survey_responses
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream survey_questions
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):182 - Copying into tables in destination started for 3 streams
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream survey_pages of schema survey_monkey into tmp table _airbyte_tmp_fhe_survey_pages to final table _airbyte_raw_survey_pages from stage path SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/ with 1 file(s) [a93b28a2-779f-480f-b38e-b97fd8df8b899550890136788251605.csv.gz]
2022-04-04 22:50:34 destination > 2022-04-04 22:50:34 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):88 - Starting copy to tmp table from stage: _airbyte_tmp_fhe_survey_pages in destination from stage: SURVEY_MONKEY_SURVEY_PAGES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/, schema: survey_monkey, .
2022-04-04 22:50:37 destination > 2022-04-04 22:50:37 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):93 - Copy to tmp table survey_monkey._airbyte_tmp_fhe_survey_pages in destination complete.
2022-04-04 22:50:37 destination > 2022-04-04 22:50:37 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream survey_questions of schema survey_monkey into tmp table _airbyte_tmp_xfo_survey_questions to final table _airbyte_raw_survey_questions from stage path SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/ with 1 file(s) [e05b96e8-6ed9-44bb-83d0-a3111147c38814730900221681580633.csv.gz]
2022-04-04 22:50:37 destination > 2022-04-04 22:50:37 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):88 - Starting copy to tmp table from stage: _airbyte_tmp_xfo_survey_questions in destination from stage: SURVEY_MONKEY_SURVEY_QUESTIONS/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/, schema: survey_monkey, .
2022-04-04 22:50:38 destination > 2022-04-04 22:50:38 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):93 - Copy to tmp table survey_monkey._airbyte_tmp_xfo_survey_questions in destination complete.
2022-04-04 22:50:38 destination > 2022-04-04 22:50:38 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream survey_responses of schema survey_monkey into tmp table _airbyte_tmp_ded_survey_responses to final table _airbyte_raw_survey_responses from stage path SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/ with 1 file(s) [5a98a019-ed1b-411a-ae64-646c9c5298c76817757554986935283.csv.gz]
2022-04-04 22:50:38 destination > 2022-04-04 22:50:38 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):88 - Starting copy to tmp table from stage: _airbyte_tmp_ded_survey_responses in destination from stage: SURVEY_MONKEY_SURVEY_RESPONSES/2022/04/04/22/D1C22D69-73CD-4F27-9B7F-512753892727/, schema: survey_monkey, .
2022-04-04 22:50:40 destination > 2022-04-04 22:50:40 INFO i.a.i.d.s.SnowflakeS3StagingSqlOperations(copyIntoTmpTableFromStage):93 - Copy to tmp table survey_monkey._airbyte_tmp_ded_survey_responses in destination complete.
2022-04-04 22:50:40 destination > 2022-04-04 22:50:40 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):213 - Executing finalization of tables.
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Finalizing tables in destination completed.
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Cleaning up destination started for 3 streams
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream survey_pages. schema survey_monkey, tmp table name: _airbyte_tmp_fhe_survey_pages
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream survey_pages. schema survey_monkey, stage: SURVEY_MONKEY_SURVEY_PAGES
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):135 - Dropping bucket object SURVEY_MONKEY_SURVEY_PAGES...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):140 - Bucket object SURVEY_MONKEY_SURVEY_PAGES has been deleted...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream survey_questions. schema survey_monkey, tmp table name: _airbyte_tmp_xfo_survey_questions
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream survey_questions. schema survey_monkey, stage: SURVEY_MONKEY_SURVEY_QUESTIONS
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):135 - Dropping bucket object SURVEY_MONKEY_SURVEY_QUESTIONS...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):140 - Bucket object SURVEY_MONKEY_SURVEY_QUESTIONS has been deleted...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream survey_responses. schema survey_monkey, tmp table name: _airbyte_tmp_ded_survey_responses
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream survey_responses. schema survey_monkey, stage: SURVEY_MONKEY_SURVEY_RESPONSES
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):135 - Dropping bucket object SURVEY_MONKEY_SURVEY_RESPONSES...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.S3StorageOperations(dropBucketObject):140 - Bucket object SURVEY_MONKEY_SURVEY_RESPONSES has been deleted...
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning up destination completed.
2022-04-04 22:50:46 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):349 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@77f5b7bf[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@79325731[data={"survey_responses":{"123":{"date_modified":"2022-04-04T14:51:18+00:00"}}},additionalProperties={}],additionalProperties={}]
2022-04-04 22:50:46 destination > 2022-04-04 22:50:46 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-04 22:50:49 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-04 22:50:49 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@feb68dd[status=completed,recordsSynced=13,bytesSynced=13225,startTime=1649112625192,endTime=1649112649590,totalStats=io.airbyte.config.SyncStats@631941f0[recordsEmitted=13,bytesEmitted=13225,stateMessagesEmitted=1,recordsCommitted=13],streamStats=[io.airbyte.config.StreamSyncStats@4748686e[streamName=survey_pages,stats=io.airbyte.config.SyncStats@7460ca3f[recordsEmitted=1,bytesEmitted=154,stateMessagesEmitted=<null>,recordsCommitted=1]], io.airbyte.config.StreamSyncStats@2019e9ee[streamName=survey_responses,stats=io.airbyte.config.SyncStats@9a62adc[recordsEmitted=1,bytesEmitted=1700,stateMessagesEmitted=<null>,recordsCommitted=1]], io.airbyte.config.StreamSyncStats@da9389e[streamName=survey_questions,stats=io.airbyte.config.SyncStats@7fea3a26[recordsEmitted=11,bytesEmitted=11371,stateMessagesEmitted=<null>,recordsCommitted=11]]]]
2022-04-04 22:50:49 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message
2022-04-04 22:50:49 INFO i.a.w.DefaultReplicationWorker(run):254 - State capture: Updated state to: Optional[io.airbyte.config.State@10d3faac[state={"survey_responses":{"123":{"date_modified":"2022-04-04T14:51:18+00:00"}}}]]
2022-04-04 22:50:49 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-04 22:50:49 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@3f93adf4[standardSyncSummary=io.airbyte.config.StandardSyncSummary@216ea42b[status=completed,recordsSynced=13,bytesSynced=13225,startTime=1649112625192,endTime=1649112649590,totalStats=io.airbyte.config.SyncStats@631941f0[recordsEmitted=13,bytesEmitted=13225,stateMessagesEmitted=1,recordsCommitted=13],streamStats=[io.airbyte.config.StreamSyncStats@4748686e[streamName=survey_pages,stats=io.airbyte.config.SyncStats@7460ca3f[recordsEmitted=1,bytesEmitted=154,stateMessagesEmitted=<null>,recordsCommitted=1]], io.airbyte.config.StreamSyncStats@2019e9ee[streamName=survey_responses,stats=io.airbyte.config.SyncStats@9a62adc[recordsEmitted=1,bytesEmitted=1700,stateMessagesEmitted=<null>,recordsCommitted=1]], io.airbyte.config.StreamSyncStats@da9389e[streamName=survey_questions,stats=io.airbyte.config.SyncStats@7fea3a26[recordsEmitted=11,bytesEmitted=11371,stateMessagesEmitted=<null>,recordsCommitted=11]]]],state=io.airbyte.config.State@10d3faac[state={"survey_responses":{"123":{"date_modified":"2022-04-04T14:51:18+00:00"}}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@47a3a014[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@709b0824[stream=io.airbyte.protocol.models.AirbyteStream@5245f7ce[name=survey_pages,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["string","null"]},"href":{"type":["string","null"]},"title":{"type":["string","null"]},"position":{"type":["integer","null"]},"description":{"type":["string","null"]},"question_count":{"type":["integer","null"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=survey_monkey,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@65e4e51[stream=io.airbyte.protocol.models.AirbyteStream@5ca7ed8e[name=survey_questions,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["string","null"]},"href":{"type":["string","null"]},"family":{"type":["string","null"]},"layout":{"type":["object","null"]},"answers":{"type":["object","null"],"properties":{"choices":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"id":{"type":["string","null"]},"text":{"type":["string","null"]},"visible":{"type":["boolean","null"]},"position":{"type":["integer","null"]},"quiz_options":{"type":["object","null"],"properties":{"score":{"type":["integer","null"]}}}}}}}},"page_id":{"type":["string","null"]},"sorting":{"type":["object","null"],"properties":{"type":{"type":["string","null"]},"ignore_last":{"type":["boolean","null"]}}},"subtype":{"type":["string","null"]},"visible":{"type":["boolean","null"]},"headings":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"heading":{"type":["string","null"]}}}},"position":{"type":["integer","null"]},"required":{"type":["object","null"],"properties":{"text":{"type":["string","null"]},"type":{"type":["string","null"]},"amount":{"type":["string","null"]}}},"validation":{"type":["object","null"],"properties":{"max":{"type":["integer","null"]},"min":{"type":["integer","null"]},"sum":{"type":["integer","null"]},"text":{"type":["string","null"]},"type":{"type":["string","null"]},"sum_text":{"type":["string","null"]}}},"forced_ranking":{"type":["boolean","null"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=survey_monkey,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@74d51416[stream=io.airbyte.protocol.models.AirbyteStream@95376c5[name=survey_responses,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["string","null"]},"href":{"type":["string","null"]},"pages":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"id":{"type":["string","null"]},"questions":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"id":{"type":["string","null"]},"answers":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"choice_id":{"type":["string","null"]}}}}}}}}}},"edit_url":{"type":["string","null"]},"metadata":{"type":["object","null"],"properties":{"contact":{"type":["object","null"]}}},"last_name":{"type":["string","null"]},"page_path":{"type":["array","null"],"items":{"type":["string","null"]}},"survey_id":{"type":["string","null"]},"first_name":{"type":["string","null"]},"ip_address":{"type":["string","null"]},"logic_path":{"type":["object","null"]},"total_time":{"type":["integer","null"]},"analyze_url":{"type":["string","null"]},"collector_id":{"type":["string","null"]},"custom_value":{"type":["string","null"]},"date_created":{"type":["string","null"],"format":"date-time"},"recipient_id":{"type":["string","null"]},"date_modified":{"type":["string","null"],"format":"date-time"},"email_address":{"type":["string","null"]},"collection_mode":{"type":["string","null"]},"response_status":{"type":["string","null"]},"custom_variables":{"type":["object","null"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date_modified],sourceDefinedPrimaryKey=[[id]],namespace=survey_monkey,additionalProperties={}],syncMode=incremental,cursorField=[date_modified],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-04 22:50:49 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-04 22:50:49 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 5c6d2228-d56d-4cc8-ad97-638b61d99e12 state: io.airbyte.config.State@420a06ac[state={"survey_responses":{"123":{"date_modified":"2022-04-04T14:51:18+00:00"}}}]
2022-04-04 22:50:49 WARN i.a.s.p.JobNotifier(notifyJob):123 - Failed to successfully notify success: io.airbyte.config.Notification@2adde57a[notificationType=slack,sendOnSuccess=false,sendOnFailure=true,slackConfiguration=io.airbyte.config.SlackNotificationConfiguration@71f72ff5[webhook=https://hooks.slack.com/services/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],customerioConfiguration=<null>,additionalProperties={}]
2022-04-04 22:50:49 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed.
errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Standard]
2022-04-04 22:50:49 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed.
errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Internal Staging]