2022-07-01 07:58:29 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-07-01 07:58:29 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-01 07:58:29 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2022-07-01 07:58:29 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: dev
2022-07-01 07:58:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-01 07:58:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-all-types:dev exists...
2022-07-01 07:58:29 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-all-types:dev was found locally.
2022-07-01 07:58:29 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5
2022-07-01 07:58:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name source-all-types-check-5-0-xzlvi --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-all-types:dev -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=5 airbyte/source-all-types:dev check --config source_config.json
2022-07-01 07:58:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-01 07:58:30 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-01 07:58:30 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2022-07-01 07:58:30 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: dev
2022-07-01 07:58:30 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-01 07:58:30 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-01 07:58:30 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-01 07:58:30 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5
2022-07-01 07:58:30 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name destination-snowflake-check-5-0-tvecf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=5 airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-01 07:58:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-01 07:58:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:31 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-01 07:58:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:31 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-01 07:58:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:31 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-01 07:58:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:31 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 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-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 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-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-01 07:58:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:32 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-01 07:58:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:34 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@70d63e05
2022-07-01 07:58:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:34 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-01 07:58:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:35 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-01 07:58:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:36 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-01 07:58:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 07:58:37 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-01 07:58:38 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-01 07:58:38 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2022-07-01 07:58:38 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: dev
2022-07-01 07:58:38 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 5 attempt id: 0
2022-07-01 07:58:38 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.TableName=full_refresh - append}
2022-07-01 07:58:38 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-01 07:58:38 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-01 07:58:38 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-01 07:58:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-01 07:58:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5
2022-07-01 07:58:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name destination-snowflake-write-5-0-zygcs --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=5 airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-01 07:58:38 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-01 07:58:38 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-all-types:dev exists...
2022-07-01 07:58:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-all-types:dev was found locally.
2022-07-01 07:58:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5
2022-07-01 07:58:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name source-all-types-read-5-0-uxbic --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-all-types:dev -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=5 airbyte/source-all-types:dev read --config source_config.json --catalog source_catalog.json
2022-07-01 07:58:38 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-01 07:58:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-01 07:58:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-01 07:58:38 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-01 07:58:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-01 07:58:38 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-01 07:58:38 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 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-07-01 07:58:39 destination > 2022-07-01 07:58:39 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-07-01 07:58:39 destination > 2022-07-01 07:58:39 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-07-01 07:58:39 destination > 2022-07-01 07:58:39 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-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45+05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45-05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999-01
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999+01
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45+05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45-05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999-01
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999+01
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45+05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45-05
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999-01
2022-07-01 07:58:39 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-11-22T01:23:45.9999999+01
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=TableName, namespace=null, outputSchemaName=TEXT_SCHEMA, tmpTableName=_airbyte_tmp_vcf_TableName, outputTableName=_airbyte_raw_TableName, syncMode=append}
2022-07-01 07:58:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):327 - Source has no more messages, closing connection.
2022-07-01 07:58:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):335 - Total records read: 1 (1 KB)
2022-07-01 07:58:39 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):338 - Schema validation errors found for stream TableName. Error messages: [$.type_object_of_datetime_with_timezone.datetime_8 is of an incorrect type. Expected it to be date-time, $.type_object_of_datetime_with_timezone.datetime_3 is of an incorrect type. Expected it to be date-time, $.type_object_of_datetime_with_timezone.datetime_4 is of an incorrect type. Expected it to be date-time, $.type_object_of_datetime_with_timezone.datetime_7 is of an incorrect type. Expected it to be date-time]
2022-07-01 07:58:39 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 1 streams
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema TEXT_SCHEMA stream TableName: tmp table: _airbyte_tmp_vcf_TableName, stage: 2022/07/01/07/3220511E-06C4-4F5B-90D2-63A29F6620E6/
2022-07-01 07:58:39 destination > 2022-07-01 07:58:39 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-01 07:58:41 destination > 2022-07-01 07:58:41 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@41b13f3d
2022-07-01 07:58:41 destination > 2022-07-01 07:58:41 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-01 07:58:42 destination > 2022-07-01 07:58:42 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema TEXT_SCHEMA stream TableName
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):48 - Starting a new buffer for stream TableName (current state: 0 bytes in 0 buffers)
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):241 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-07-01 07:58:43 destination > Ideally, this situation should not happen...
2022-07-01 07:58:43 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-07-01 07:58:43 destination > The main thread is: main (RUNNABLE)
2022-07-01 07:58:43 destination >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:276)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:245)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:202)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:165)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:165)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107)
2022-07-01 07:58:43 destination >         at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30)
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):255 - Active non-daemon thread: pool-4-thread-1 (RUNNABLE)
2022-07-01 07:58:43 destination >  Thread stacktrace: java.base@17.0.1/sun.nio.ch.Net.poll(Native Method)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.park(NioSocketImpl.java:181)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.timedRead(NioSocketImpl.java:285)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:309)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/java.net.Socket$SocketInputStream.read(Socket.java:966)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:478)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:472)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1455)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1059)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.RestRequest.execute(RestRequest.java:160)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.core.HttpUtil.executeRequestInternal(HttpUtil.java:639)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.core.HttpUtil.executeRequest(HttpUtil.java:584)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.core.HttpUtil.executeGeneralRequest(HttpUtil.java:551)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.sendBatch(TelemetryClient.java:256)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.lambda$sendBatchAsync$0(TelemetryClient.java:204)
2022-07-01 07:58:43 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient$$Lambda$254/0x0000000801000e88.call(Unknown Source)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-07-01 07:58:43 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):103 - Flushing all 1 current buffers (0 bytes in total)
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):106 - Flushing buffer of stream TableName (10 bytes)
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream TableName (10 bytes) to staging
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-07-01 07:58:43 destination > 2022-07-01 07:58:43 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 4ba42f4b-fde6-4699-853f-751df03b0ebf18246396853165886596.csv.gz (377 bytes)
2022-07-01 07:58:45 destination > 2022-07-01 07:58:45 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-01 07:58:45 destination > 2022-07-01 07:58:45 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 4ba42f4b-fde6-4699-853f-751df03b0ebf18246396853165886596.csv.gz
2022-07-01 07:58:45 destination > 2022-07-01 07:58:45 INFO i.a.i.d.r.SerializedBufferingStrategy(close):127 - Closing buffer for stream TableName
2022-07-01 07:58:45 destination > 2022-07-01 07:58:45 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 1 streams
2022-07-01 07:58:45 destination > 2022-07-01 07:58:45 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream TableName of schema TEXT_SCHEMA into tmp table _airbyte_tmp_vcf_TableName to final table _airbyte_raw_TableName from stage path 2022/07/01/07/3220511E-06C4-4F5B-90D2-63A29F6620E6/ with 1 file(s) [4ba42f4b-fde6-4699-853f-751df03b0ebf18246396853165886596.csv.gz]
2022-07-01 07:58:47 destination > 2022-07-01 07:58:47 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination.
2022-07-01 07:58:47 destination > 2022-07-01 07:58:47 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):216 - Executing finalization of tables.
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):218 - Finalizing tables in destination completed.
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):220 - Cleaning up destination started for 1 streams
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream TableName. schema TEXT_SCHEMA, tmp table name: _airbyte_tmp_vcf_TableName
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream TableName. schema TEXT_SCHEMA, stage: TEXT_SCHEMA_TABLENAME
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):235 - Cleaning up destination completed.
2022-07-01 07:58:49 destination > 2022-07-01 07:58:49 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-01 07:58:51 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-07-01 07:58:51 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4f62cb72[status=completed,recordsSynced=1,bytesSynced=1079,startTime=1656662318410,endTime=1656662331216,totalStats=io.airbyte.config.SyncStats@15170332[recordsEmitted=1,bytesEmitted=1079,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@f772277[streamName=TableName,stats=io.airbyte.config.SyncStats@52c748fb[recordsEmitted=1,bytesEmitted=1079,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-07-01 07:58:51 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-01 07:58:51 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-07-01 07:58:51 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-01 07:58:51 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@4c16634[standardSyncSummary=io.airbyte.config.StandardSyncSummary@13b54eff[status=completed,recordsSynced=1,bytesSynced=1079,startTime=1656662318410,endTime=1656662331216,totalStats=io.airbyte.config.SyncStats@15170332[recordsEmitted=1,bytesEmitted=1079,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@f772277[streamName=TableName,stats=io.airbyte.config.SyncStats@52c748fb[recordsEmitted=1,bytesEmitted=1079,stateMessagesEmitted=<null>,recordsCommitted=1]]]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@358fc492[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6b11b2eb[stream=io.airbyte.protocol.models.AirbyteStream@64ee997b[name=TableName,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"type_date":{"type":"string","format":"date"},"type_binary":{"type":"string","contentEncoding":"base64"},"type_number":{"type":"number"},"type_object":{"type":"object","properties":{"type_number":{"type":"number"},"type_string":{"type":"string"},"type_boolean":{"type":"boolean"},"type_integer":{"type":"integer"}}},"type_string":{"type":"string"},"type_boolean":{"type":"boolean"},"type_integer":{"type":"integer"},"type_big_number":{"type":"string","airbyte_type":"big_number"},"type_big_integer":{"type":"string","airbyte_type":"big_integer"},"type_array_of_strings":{"type":"array","items":{"type":"string"}},"type_datetime_with_timezone":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"type_datetime_without_timezone":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"type_object_of_datetime_with_timezone":{"type":"object","properties":{"datetime_1":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_2":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_3":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_4":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_5":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_6":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_7":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"},"datetime_8":{"type":"string","format":"date-time","airbyte_type":"timestamp_with_timezone"}}},"type_object_of_datetime_without_timezone":{"type":"object","properties":{"datetime_1":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"datetime_2":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-07-01 07:58:51 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...