2022-04-26 00:38:17 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.3-alpha 2022-04-26 00:38:17 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/92/1/logs.log 2022-04-26 00:38:25 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-26 00:38:25 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-26 00:38:25 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-26 00:38:25 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-26 00:38:25 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-26 00:38:53 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.storage: must be a constant value HTTPS 2022-04-26 00:38:53 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.storage: must be a constant value GCS 2022-04-26 00:38:53 INFO 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:38:53 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-04-26 00:38:17 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.63-alpha 2022-04-26 00:38:18 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 92 attempt id: 1 2022-04-26 00:38:18 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.country_populations=full_refresh - append} 2022-04-26 00:38:18 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-26 00:38:18 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-snowflake-sync-92-1-xdlij for airbyte/destination-snowflake:0.4.24 2022-04-26 00:38:18 INFO i.a.w.p.KubeProcessFactory(create):116 - destination-snowflake-sync-92-1-xdlij stdoutLocalPort = 9036 2022-04-26 00:38:18 INFO i.a.w.p.KubeProcessFactory(create):119 - destination-snowflake-sync-92-1-xdlij stderrLocalPort = 9037 2022-04-26 00:38:18 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server... 2022-04-26 00:38:18 INFO i.a.w.p.KubePodProcess():512 - Creating pod destination-snowflake-sync-92-1-xdlij... 2022-04-26 00:38:18 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server... 2022-04-26 00:38:19 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-26 00:38:19 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-04-26 00:38:20 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-04-26 00:38:20 INFO i.a.w.p.KubePodProcess():543 - Copying files... 2022-04-26 00:38:20 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-26 00:38:20 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/1d9940f0-67df-4192-980c-f5dfff2f17aa/destination_config.json dcw-dev123/destination-snowflake-sync-92-1-xdlij:/config/destination_config.json -c init 2022-04-26 00:38:20 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/8cbd4180-be14-4e4b-9556-5c43a98b6e65/destination_catalog.json dcw-dev123/destination-snowflake-sync-92-1-xdlij:/config/destination_catalog.json -c init 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/e6d0983f-e59d-4c84-9d70-affdd84557a0/FINISHED_UPLOADING dcw-dev123/destination-snowflake-sync-92-1-xdlij:/config/FINISHED_UPLOADING -c init 2022-04-26 00:38:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:22 INFO i.a.w.p.KubePodProcess():546 - Waiting until pod is ready... 2022-04-26 00:38:24 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout... 2022-04-26 00:38:24 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess():561 - Reading pod IP... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess():563 - Pod IP: 10.244.8.73 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess():566 - Creating stdin socket... 2022-04-26 00:38:25 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = source-file-sync-92-1-ptfev for airbyte/source-file:0.2.10 2022-04-26 00:38:25 INFO i.a.w.p.KubeProcessFactory(create):116 - source-file-sync-92-1-ptfev stdoutLocalPort = 9038 2022-04-26 00:38:25 INFO i.a.w.p.KubeProcessFactory(create):119 - source-file-sync-92-1-ptfev stderrLocalPort = 9039 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):580 - Creating stdout socket server... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):598 - Creating stderr socket server... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess():512 - Creating pod source-file-sync-92-1-ptfev... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-26 00:38:25 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-04-26 00:38:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-04-26 00:38:27 INFO i.a.w.p.KubePodProcess():543 - Copying files... 2022-04-26 00:38:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json 2022-04-26 00:38:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a92d8e04-408a-484d-8cec-785728716133/input_state.json dcw-dev123/source-file-sync-92-1-ptfev:/config/input_state.json -c init 2022-04-26 00:38:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/9de873eb-4270-4ff3-b606-d489efc04751/source_config.json dcw-dev123/source-file-sync-92-1-ptfev:/config/source_config.json -c init 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/d7a30662-c369-459a-8339-81c0c5de1689/source_catalog.json dcw-dev123/source-file-sync-92-1-ptfev:/config/source_catalog.json -c init 2022-04-26 00:38:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/00aadcc5-a853-4590-aa04-ae7e72126f8e/FINISHED_UPLOADING dcw-dev123/source-file-sync-92-1-ptfev:/config/FINISHED_UPLOADING -c init 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 00:38:29 INFO i.a.w.p.KubePodProcess():546 - Waiting until pod is ready... 2022-04-26 00:38:30 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):589 - Setting stdout... 2022-04-26 00:38:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Setting stderr... 2022-04-26 00:38:32 INFO i.a.w.p.KubePodProcess():561 - Reading pod IP... 2022-04-26 00:38:32 INFO i.a.w.p.KubePodProcess():563 - Pod IP: 10.244.8.74 2022-04-26 00:38:32 INFO i.a.w.p.KubePodProcess():570 - Using null stdin output stream... 2022-04-26 00:38:32 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-26 00:38:32 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-26 00:38:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-26 00:38:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (93 KB) 2022-04-26 00:38:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (187 KB) 2022-04-26 00:38:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (272 KB) 2022-04-26 00:38:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (347 KB) 2022-04-26 00:38:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (424 KB) 2022-04-26 00:38:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (499 KB) 2022-04-26 00:38:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (575 KB) 2022-04-26 00:38:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (649 KB) 2022-04-26 00:38:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (724 KB) 2022-04-26 00:38:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (798 KB) 2022-04-26 00:38:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (873 KB) 2022-04-26 00:38:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (949 KB) 2022-04-26 00:38:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (1 MB) 2022-04-26 00:38:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (1 MB) 2022-04-26 00:38:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (1 MB) 2022-04-26 00:38:43 INFO i.a.w.p.KubePodProcess(close):710 - (pod: dcw-dev123 / source-file-sync-92-1-ptfev) - Closed all resources for pod 2022-04-26 00:38:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 15409 (1 MB) 2022-04-26 00:38:43 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-04-26 00:38:52 INFO i.a.w.p.KubePodProcess(close):710 - (pod: dcw-dev123 / destination-snowflake-sync-92-1-xdlij) - Closed all resources for pod 2022-04-26 00:38:52 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete. 2022-04-26 00:38:52 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6ea50857[status=completed,recordsSynced=15409,bytesSynced=1241460,startTime=1650933498491,endTime=1650933532591,totalStats=io.airbyte.config.SyncStats@3fc182b4[recordsEmitted=15409,bytesEmitted=1241460,stateMessagesEmitted=0,recordsCommitted=15409],streamStats=[io.airbyte.config.StreamSyncStats@11b6010a[streamName=country_populations,stats=io.airbyte.config.SyncStats@6c3b35bd[recordsEmitted=15409,bytesEmitted=1241460,stateMessagesEmitted=,recordsCommitted=15409]]]] 2022-04-26 00:38:52 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-26 00:38:52 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@745c5ee2[state={}] 2022-04-26 00:38:52 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-26 00:38:52 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@73e96cfa[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6e119353[status=completed,recordsSynced=15409,bytesSynced=1241460,startTime=1650933498491,endTime=1650933532591,totalStats=io.airbyte.config.SyncStats@3fc182b4[recordsEmitted=15409,bytesEmitted=1241460,stateMessagesEmitted=0,recordsCommitted=15409],streamStats=[io.airbyte.config.StreamSyncStats@11b6010a[streamName=country_populations,stats=io.airbyte.config.SyncStats@6c3b35bd[recordsEmitted=15409,bytesEmitted=1241460,stateMessagesEmitted=,recordsCommitted=15409]]]],normalizationSummary=,state=io.airbyte.config.State@745c5ee2[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@615908b4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@f0a9bf5[stream=io.airbyte.protocol.models.AirbyteStream@37bcb852[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=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-04-26 00:38:52 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-26 00:38:52 INFO i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection 3a0b9eb0-4179-4d58-9d4a-8e0717b2a7a0 state: io.airbyte.config.State@2574a365[state={}] 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):339 - Sentry transaction event: e5f0e591657842f3a20e088d3afa6a02 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 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-26 00:38:32 destination > 2022-04-26 00:38:26 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-26 00:38:32 destination > 2022-04-26 00:38:26 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-26 00:38:32 destination > 2022-04-26 00:38:26 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-26 00:38:32 destination > 2022-04-26 00:38:26 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-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=country_populations, namespace=null, outputSchemaName=RAW, tmpTableName=_airbyte_tmp_nil_country_populations, outputTableName=_airbyte_raw_country_populations, syncMode=append} 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 1 streams 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO 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_nil_country_populations, stage: 2022/04/26/00/5EB06D3A-871A-41EB-8518-89C2EF41E91E/ 2022-04-26 00:38:32 destination > 2022-04-26 00:38:26 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-04-26 00:38:32 destination > 2022-04-26 00:38:29 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@670f2466 2022-04-26 00:38:32 destination > 2022-04-26 00:38:29 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-04-26 00:38:32 destination > 2022-04-26 00:38:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 00:38:32 destination > 2022-04-26 00:38:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema RAW stream country_populations 2022-04-26 00:38:32 destination > 2022-04-26 00:38:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed. 2022-04-26 00:38:33 source > Reading country_populations (s3://convexa-local/datacoves_demo/country_populations.csv)... 2022-04-26 00:38:34 destination > 2022-04-26 00:38:34 INFO 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:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-04-26 00:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-04-26 00:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 1 current buffers (489 KB in total) 2022-04-26 00:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream country_populations (489 KB) 2022-04-26 00:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream country_populations (489 KB) to staging 2022-04-26 00:38:44 destination > 2022-04-26 00:38:44 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to fd5b4597-826d-4f07-9d1f-bf514078343d549179723571276388.csv.gz (503 KB) 2022-04-26 00:38:46 destination > 2022-04-26 00:38:46 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 00:38:46 destination > 2022-04-26 00:38:46 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data fd5b4597-826d-4f07-9d1f-bf514078343d549179723571276388.csv.gz 2022-04-26 00:38:46 destination > 2022-04-26 00:38:46 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream country_populations 2022-04-26 00:38:46 destination > 2022-04-26 00:38:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):182 - Copying into tables in destination started for 1 streams 2022-04-26 00:38:46 destination > 2022-04-26 00:38:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream country_populations of schema RAW into tmp table _airbyte_tmp_nil_country_populations to final table _airbyte_raw_country_populations from stage path 2022/04/26/00/5EB06D3A-871A-41EB-8518-89C2EF41E91E/ with 1 file(s) [fd5b4597-826d-4f07-9d1f-bf514078343d549179723571276388.csv.gz] 2022-04-26 00:38:48 destination > 2022-04-26 00:38:48 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):213 - Executing finalization of tables. 2022-04-26 00:38:50 destination > 2022-04-26 00:38:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Finalizing tables in destination completed. 2022-04-26 00:38:50 destination > 2022-04-26 00:38:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Cleaning up destination started for 1 streams 2022-04-26 00:38:50 destination > 2022-04-26 00:38:50 INFO 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_nil_country_populations 2022-04-26 00:38:50 destination > 2022-04-26 00:38:50 INFO 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:38:50 destination > 2022-04-26 00:38:50 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning up destination completed. 2022-04-26 00:38:50 destination > 2022-04-26 00:38:50 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination