2022-04-25 22:23:15 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.3-alpha
2022-04-25 22:23:21 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/92/0/logs.log
2022-04-25 22:23:21 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.63-alpha
2022-04-25 22:23:38 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-25 22:23:24 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-25 22:23:24 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword existingJavaType - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-25 22:23:24 [32mINFO[m i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 92 attempt id: 0
2022-04-25 22:23:24 [32mINFO[m i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.country_populations=full_refresh - append}
2022-04-25 22:23:24 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-snowflake-sync-92-0-gerqh for airbyte/destination-snowflake:0.4.24
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubeProcessFactory(create):116 - destination-snowflake-sync-92-0-gerqh stdoutLocalPort = 9024
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubeProcessFactory(create):119 - destination-snowflake-sync-92-0-gerqh stderrLocalPort = 9025
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server...
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server...
2022-04-25 22:23:25 [32mINFO[m i.a.w.p.KubePodProcess(<init>):512 - Creating pod destination-snowflake-sync-92-0-gerqh...
2022-04-25 22:23:31 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-04-25 22:23:32 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-04-25 22:23:32 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-04-25 22:23:32 [32mINFO[m i.a.w.p.KubePodProcess(<init>):543 - Copying files...
2022-04-25 22:23:32 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json
2022-04-25 22:23:32 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/c2114235-3699-49d6-b62e-9dee1756baef/destination_config.json dcw-dev123/destination-snowflake-sync-92-0-gerqh:/config/destination_config.json -c init
2022-04-25 22:23:33 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:33 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:33 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json
2022-04-25 22:23:33 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/d6debf51-abb7-4f78-b655-1c8b67b5011c/destination_catalog.json dcw-dev123/destination-snowflake-sync-92-0-gerqh:/config/destination_catalog.json -c init
2022-04-25 22:23:33 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/3fe89642-930b-4457-9fb5-dca53d50b444/FINISHED_UPLOADING dcw-dev123/destination-snowflake-sync-92-0-gerqh:/config/FINISHED_UPLOADING -c init
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:34 [32mINFO[m i.a.w.p.KubePodProcess(<init>):546 - Waiting until pod is ready...
2022-04-25 22:23:36 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout...
2022-04-25 22:23:36 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr...
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):561 - Reading pod IP...
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):563 - Pod IP: 10.244.8.67
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubePodProcess(<init>):566 - Creating stdin socket...
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = source-file-sync-92-0-lvofy for airbyte/source-file:0.2.10
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubeProcessFactory(create):116 - source-file-sync-92-0-lvofy stdoutLocalPort = 9026
2022-04-25 22:23:37 [32mINFO[m i.a.w.p.KubeProcessFactory(create):119 - source-file-sync-92-0-lvofy stderrLocalPort = 9027
2022-04-25 22:23:38 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server...
2022-04-25 22:23:38 [32mINFO[m i.a.w.p.KubePodProcess(<init>):512 - Creating pod source-file-sync-92-0-lvofy...
2022-04-25 22:23:38 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server...
2022-04-25 22:23:39 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-04-25 22:23:39 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(<init>):543 - Copying files...
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/1c7d4c5e-1447-4c8a-ae95-6530cfb66283/input_state.json dcw-dev123/source-file-sync-92-0-lvofy:/config/input_state.json -c init
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/2f0f9801-323d-4dd7-a867-154f3ea9d2e8/source_config.json dcw-dev123/source-file-sync-92-0-lvofy:/config/source_config.json -c init
2022-04-25 22:23:40 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:41 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:41 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json
2022-04-25 22:23:41 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/fa1ceeac-ead1-4ed9-894b-d63ada6e279d/source_catalog.json dcw-dev123/source-file-sync-92-0-lvofy:/config/source_catalog.json -c init
2022-04-25 22:23:41 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/636a7d50-7fca-46b5-9cf7-018e8d2f3c27/FINISHED_UPLOADING dcw-dev123/source-file-sync-92-0-lvofy:/config/FINISHED_UPLOADING -c init
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-04-25 22:23:42 [32mINFO[m i.a.w.p.KubePodProcess(<init>):546 - Waiting until pod is ready...
2022-04-25 22:23:44 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout...
2022-04-25 22:23:44 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr...
2022-04-25 22:23:44 [32mINFO[m i.a.w.p.KubePodProcess(<init>):561 - Reading pod IP...
2022-04-25 22:23:44 [32mINFO[m i.a.w.p.KubePodProcess(<init>):563 - Pod IP: 10.244.8.68
2022-04-25 22:23:44 [32mINFO[m i.a.w.p.KubePodProcess(<init>):570 - Using null stdin output stream...
2022-04-25 22:23:45 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-25 22:23:45 [32mINFO[m i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-25 22:23:45 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-25 22:23:52 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (93 KB)
2022-04-25 22:23:53 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (187 KB)
2022-04-25 22:23:54 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (272 KB)
2022-04-25 22:23:56 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (347 KB)
2022-04-25 22:23:57 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (424 KB)
2022-04-25 22:23:58 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (499 KB)
2022-04-25 22:23:59 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (575 KB)
2022-04-25 22:24:00 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (649 KB)
2022-04-25 22:24:01 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (724 KB)
2022-04-25 22:24:02 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (798 KB)
2022-04-25 22:24:03 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (873 KB)
2022-04-25 22:24:04 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (949 KB)
2022-04-25 22:24:05 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (1 MB)
2022-04-25 22:24:05 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (1 MB)
2022-04-25 22:23:38 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-25 22:23:38 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-25 22:23:38 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-25 22:23:38 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.b.IntegrationRunner(createSentryTransaction):339 - Sentry transaction event: beb10c0e8b3c470089ca1de718207b1a
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [33mWARN[m 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-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=country_populations, namespace=null, outputSchemaName=RAW, tmpTableName=_airbyte_tmp_hsr_country_populations, outputTableName=_airbyte_raw_country_populations, syncMode=append}
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 1 streams
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema RAW stream country_populations: tmp table: _airbyte_tmp_hsr_country_populations, stage: 2022/04/25/22/EFD7FC52-4BE6-4234-AAFC-72C868EE53A3/
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:38 [32mINFO[m c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:40 [32mINFO[m c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@670f2466
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:40 [32mINFO[m c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:41 [32mINFO[m i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:42 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema RAW stream country_populations
2022-04-25 22:23:45 [43mdestination[0m > 2022-04-25 22:23:42 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed.
2022-04-25 22:23:46 [44msource[0m > Reading country_populations (s3://convexa-local/datacoves_demo/country_populations.csv)...
2022-04-25 22:23:48 [43mdestination[0m > 2022-04-25 22:23:48 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream country_populations (current state: 0 bytes in 0 buffers)
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-26 00:36:58 [32mINFO[m i.a.w.p.KubePodProcess(close):710 - (pod: dcw-dev123 / source-file-sync-92-0-lvofy) - Closed all resources for pod
2022-04-26 00:37:10 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: must be a constant value HTTPS
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 1 current buffers (465 KB in total)
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream country_populations (465 KB)
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream country_populations (465 KB) to staging
2022-04-26 00:36:58 [43mdestination[0m > 2022-04-26 00:36:58 [32mINFO[m i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 2a56ff5c-1039-4516-96fc-0c35ac39ab923722345223901980618.csv.gz (479 KB)
2022-04-26 00:37:02 [43mdestination[0m > 2022-04-26 00:37:02 [32mINFO[m i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-26 00:37:02 [43mdestination[0m > 2022-04-26 00:37:02 [32mINFO[m i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 2a56ff5c-1039-4516-96fc-0c35ac39ab923722345223901980618.csv.gz
2022-04-26 00:37:02 [43mdestination[0m > 2022-04-26 00:37:02 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream country_populations
2022-04-26 00:37:02 [43mdestination[0m > 2022-04-26 00:37:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):182 - Copying into tables in destination started for 1 streams
2022-04-26 00:37:02 [43mdestination[0m > 2022-04-26 00:37:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream country_populations of schema RAW into tmp table _airbyte_tmp_hsr_country_populations to final table _airbyte_raw_country_populations from stage path 2022/04/25/22/EFD7FC52-4BE6-4234-AAFC-72C868EE53A3/ with 1 file(s) [2a56ff5c-1039-4516-96fc-0c35ac39ab923722345223901980618.csv.gz]
2022-04-26 00:37:04 [43mdestination[0m > 2022-04-26 00:37:04 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):213 - Executing finalization of tables.
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Finalizing tables in destination completed.
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Cleaning up destination started for 1 streams
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream country_populations. schema RAW, tmp table name: _airbyte_tmp_hsr_country_populations
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream country_populations. schema RAW, stage: RAW_COUNTRY_POPULATIONS
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning up destination completed.
2022-04-26 00:37:07 [43mdestination[0m > 2022-04-26 00:37:07 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-26 00:37:09 [32mINFO[m i.a.w.p.KubePodProcess(close):710 - (pod: dcw-dev123 / destination-snowflake-sync-92-0-gerqh) - Closed all resources for pod
2022-04-26 00:37:09 [1;31mERROR[m i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:326) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at java.io.BufferedReader$1.hasNext(BufferedReader.java:574) ~[?:?]
	at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1855) ~[?:?]
	at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) ~[?:?]
	at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) ~[?:?]
	at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:169) ~[?:?]
	at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) ~[?:?]
	at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.isFinished(DefaultAirbyteSource.java:93) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:282) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.net.SocketException: Connection timed out
	at sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:325) ~[?:?]
	at sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350) ~[?:?]
	at sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803) ~[?:?]
	at java.net.Socket$SocketInputStream.read(Socket.java:966) ~[?:?]
	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:270) ~[?:?]
	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:313) ~[?:?]
	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:188) ~[?:?]
	at java.io.InputStreamReader.read(InputStreamReader.java:177) ~[?:?]
	at java.io.BufferedReader.fill(BufferedReader.java:162) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:329) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:396) ~[?:?]
	at java.io.BufferedReader$1.hasNext(BufferedReader.java:571) ~[?:?]
	at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1855) ~[?:?]
	at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) ~[?:?]
	at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) ~[?:?]
	at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:169) ~[?:?]
	at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) ~[?:?]
	at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.isFinished(DefaultAirbyteSource.java:93) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:282) ~[io.airbyte-airbyte-workers-0.36.3-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-26 00:37:09 [32mINFO[m i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@ce34391[status=failed,recordsSynced=14712,bytesSynced=1185990,startTime=1650925404992,endTime=1650933429203,totalStats=io.airbyte.config.SyncStats@64b21c1b[recordsEmitted=14712,bytesEmitted=1185990,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@649b1ab2[streamName=country_populations,stats=io.airbyte.config.SyncStats@361dc845[recordsEmitted=14712,bytesEmitted=1185990,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-26 00:37:09 [32mINFO[m i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-26 00:37:09 [33mWARN[m i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@37822acc[state={}]
2022-04-26 00:37:09 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-26 00:37:09 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@4dcfa38a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@7a2f9b6d[status=failed,recordsSynced=14712,bytesSynced=1185990,startTime=1650925404992,endTime=1650933429203,totalStats=io.airbyte.config.SyncStats@64b21c1b[recordsEmitted=14712,bytesEmitted=1185990,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@649b1ab2[streamName=country_populations,stats=io.airbyte.config.SyncStats@361dc845[recordsEmitted=14712,bytesEmitted=1185990,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],normalizationSummary=<null>,state=io.airbyte.config.State@37822acc[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@fd34cc9[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@552cc68e[stream=io.airbyte.protocol.models.AirbyteStream@654fec52[name=country_populations,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"Year":{"type":["number","null"]},"Value":{"type":["number","null"]},"Country Code":{"type":["string","null"]},"Country Name":{"type":["string","null"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@63bdf765[failureOrigin=replication,failureType=<null>,internalMessage=java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Connection timed out,externalMessage=Something went wrong during replication,metadata=io.airbyte.config.Metadata@761d5adf[additionalProperties={attemptNumber=0, jobId=92}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:326)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.io.UncheckedIOException: java.net.SocketException: Connection timed out
	at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:574)
	at java.base/java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1855)
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292)
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206)
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:169)
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298)
	at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.isFinished(DefaultAirbyteSource.java:93)
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:282)
	... 4 more
Caused by: java.net.SocketException: Connection timed out
	at java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:325)
	at java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
	at java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
	at java.base/java.net.Socket$SocketInputStream.read(Socket.java:966)
	at java.base/sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:270)
	at java.base/sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:313)
	at java.base/sun.nio.cs.StreamDecoder.read(StreamDecoder.java:188)
	at java.base/java.io.InputStreamReader.read(InputStreamReader.java:177)
	at java.base/java.io.BufferedReader.fill(BufferedReader.java:162)
	at java.base/java.io.BufferedReader.readLine(BufferedReader.java:329)
	at java.base/java.io.BufferedReader.readLine(BufferedReader.java:396)
	at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:571)
	... 12 more
,retryable=<null>,timestamp=1650933418136]]]
2022-04-26 00:37:09 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-26 00:37:09 [32mINFO[m i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection 3a0b9eb0-4179-4d58-9d4a-8e0717b2a7a0 state: io.airbyte.config.State@630249dc[state={}]
2022-04-26 00:37:10 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.storage: must be a constant value GCS
2022-04-26 00:37:10 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-04-26 00:37:10 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]