2022-07-15 21:09:55 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-15 21:09:55 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-15 21:09:55 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/0/logs.log
2022-07-15 21:09:55 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:09:56 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:09:56 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:09:58 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:09:58 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/0 --log-driver none --name source-mixpanel-check-2626-0-esqzd --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-15 21:09:58 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:10:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-15 21:10:06 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:10:06 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/0/logs.log
2022-07-15 21:10:06 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:10:06 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:10:06 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:10:06 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:10:06 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:10:06 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/0 --log-driver none --name destination-snowflake-check-2626-0-hewev --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-15 21:10:07 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:10:07 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-15 21:10:07 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-15 21:10:07 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-15 21:10:07 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:10:07 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 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-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 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-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 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-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 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-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-15 21:10:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:09 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:11 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3b705be7
2022-07-15 21:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:11 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:10:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:11 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:10:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:12 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-15 21:10:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:10:12 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-15 21:10:13 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:10:14 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/0/logs.log
2022-07-15 21:10:14 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:10:14 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 2626 attempt id: 0
2022-07-15 21:10:14 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.export=incremental - append, null.funnels=incremental - append, null.revenue=incremental - append}
2022-07-15 21:10:14 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-15 21:10:14 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:10:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:10:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:10:14 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:10:14 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/0 --log-driver none --name destination-snowflake-write-2626-0-molab --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-15 21:10:14 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:10:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:10:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:10:14 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:10:14 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/0 --log-driver none --name source-mixpanel-read-2626-0-blhyc --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json
2022-07-15 21:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-15 21:10:14 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-15 21:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-15 21:10:15 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:10:15 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:10:15 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:10:15 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:10:15 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:10:15 source > Starting syncing SourceMixpanel
2022-07-15 21:10:15 source > Using start_date: 2022-07-01, end_date: 2022-07-15
2022-07-15 21:10:15 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:10:15 source > Syncing stream: export 
2022-07-15 21:10:17 destination > 2022-07-15 21:10:17 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-15 21:10:17 destination > 2022-07-15 21:10:17 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:10:17 destination > 2022-07-15 21:10:17 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:10:17 destination > 2022-07-15 21:10:17 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-15 21:10:17 destination > 2022-07-15 21:10:17 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-15 21:10:17 destination > 2022-07-15 21:10:17 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-15 21:10:17 destination > 2022-07-15 21:10:17 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-15 21:10:17 destination > 2022-07-15 21:10:17 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-15 21:10:17 destination > 2022-07-15 21:10:17 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_kgs_export, outputTableName=_airbyte_raw_export, syncMode=append}
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_uzm_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append}
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_ekx_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append}
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 3 streams
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream export: tmp table: _airbyte_tmp_kgs_export, stage: 2022/07/15/21/E2964D5F-4949-4AB0-8494-E934A5A9E809/
2022-07-15 21:10:18 destination > 2022-07-15 21:10:18 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:10:20 destination > 2022-07-15 21:10:20 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@29ebbdf4
2022-07-15 21:10:20 destination > 2022-07-15 21:10:20 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:10:20 destination > 2022-07-15 21:10:20 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream export
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream funnels: tmp table: _airbyte_tmp_uzm_funnels, stage: 2022/07/15/21/E2964D5F-4949-4AB0-8494-E934A5A9E809/
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream funnels
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream revenue: tmp table: _airbyte_tmp_ekx_revenue, stage: 2022/07/15/21/E2964D5F-4949-4AB0-8494-E934A5A9E809/
2022-07-15 21:10:21 destination > 2022-07-15 21:10:21 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:10:22 destination > 2022-07-15 21:10:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream revenue
2022-07-15 21:10:22 destination > 2022-07-15 21:10:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-15 21:20:31 destination > 2022-07-15 21:18:28 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=1m6s342ms469µs279ns).
2022-07-15 21:20:34 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation...
2022-07-15 21:20:34 INFO i.a.w.g.DefaultReplicationWorker(cancel):443 - Cancelling replication worker...
2022-07-15 21:20:44 INFO i.a.w.g.DefaultReplicationWorker(cancel):451 - Cancelling destination...
2022-07-15 21:20:44 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-07-15 21:20:44 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-07-15 21:20:44 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-07-15 21:20:44 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-07-15 21:20:44 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-07-15 21:20:44 INFO i.a.w.g.DefaultReplicationWorker(cancel):458 - Cancelling source...
2022-07-15 21:20:44 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-07-15 21:20:44 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-07-15 21:20:46 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-07-15 21:20:46 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread...
2022-07-15 21:20:46 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future...
2022-07-15 21:20:46 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-15 21:20:46 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-15 21:20:46 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-07-15 21:20:46 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-07-15 21:20:46 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@70f84154[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1657919414114,endTime=1657920046452,totalStats=io.airbyte.config.SyncStats@22288a4b[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-07-15 21:20:46 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-15 21:20:46 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-07-15 21:20:46 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:20:46 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-15 21:20:46 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=0d173df7-663c-3a2e-b8da-c7cf8d3c2013, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor379.invoke(Unknown Source) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:207) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2022-07-15 21:20:35 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-15 21:20:35 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-15 21:20:35 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-15 21:20:35 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-15 21:20:35 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/1/logs.log
2022-07-15 21:20:35 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:20:35 INFO i.a.c.f.EnvVariableFeatureFlags(autoDisablesFailingConnections):17 - Auto Disable Failing Connections: false
2022-07-15 21:20:36 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:20:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:20:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:20:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:20:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/1 --log-driver none --name source-mixpanel-check-2626-1-gozrb --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-15 21:20:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-15 21:20:52 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:20:52 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/1/logs.log
2022-07-15 21:20:52 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:20:52 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:20:52 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:20:53 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:20:53 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:20:53 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/1 --log-driver none --name destination-snowflake-check-2626-1-tkqzg --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-15 21:20:59 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:20:59 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-15 21:20:59 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-15 21:20:59 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-15 21:20:59 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:21:00 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:21:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:11 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-15 21:21:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:12 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:21:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:12 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-15 21:21:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:12 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-15 21:21:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:13 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-15 21:21:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:14 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-15 21:21:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:14 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-15 21:21:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:14 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-15 21:21:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:14 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-15 21:21:19 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:19 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:21:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:27 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3b705be7
2022-07-15 21:21:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:27 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:21:27 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:21:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:28 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-15 21:21:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:29 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-15 21:21:30 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:21:31 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/1/logs.log
2022-07-15 21:21:31 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:21:31 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 2626 attempt id: 1
2022-07-15 21:21:31 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.export=incremental - append, null.funnels=incremental - append, null.revenue=incremental - append}
2022-07-15 21:21:31 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-15 21:21:31 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:21:31 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:21:32 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:21:32 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/1 --log-driver none --name destination-snowflake-write-2626-1-bjxyy --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-15 21:21:32 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:21:32 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:21:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:21:33 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:21:33 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/1 --log-driver none --name source-mixpanel-read-2626-1-nluqq --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json
2022-07-15 21:21:33 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:21:33 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-15 21:21:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-15 21:21:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-15 21:21:39 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:21:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:21:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:21:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:21:39 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:21:40 source > Starting syncing SourceMixpanel
2022-07-15 21:21:40 source > Using start_date: 2022-07-01, end_date: 2022-07-15
2022-07-15 21:21:40 source > Syncing stream: export 
2022-07-15 21:21:40 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:21:51 destination > 2022-07-15 21:21:51 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-15 21:21:51 destination > 2022-07-15 21:21:51 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:21:51 destination > 2022-07-15 21:21:51 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:21:51 destination > 2022-07-15 21:21:51 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-15 21:21:52 destination > 2022-07-15 21:21:52 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-15 21:21:52 destination > 2022-07-15 21:21:52 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-15 21:21:52 destination > 2022-07-15 21:21:52 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-15 21:21:52 destination > 2022-07-15 21:21:52 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-15 21:21:53 destination > 2022-07-15 21:21:53 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-15 21:21:57 destination > 2022-07-15 21:21:56 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_tyt_export, outputTableName=_airbyte_raw_export, syncMode=append}
2022-07-15 21:21:57 destination > 2022-07-15 21:21:57 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_gcd_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append}
2022-07-15 21:21:57 destination > 2022-07-15 21:21:57 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_ali_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append}
2022-07-15 21:21:58 destination > 2022-07-15 21:21:58 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-15 21:21:58 destination > 2022-07-15 21:21:58 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 3 streams
2022-07-15 21:21:58 destination > 2022-07-15 21:21:58 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream export: tmp table: _airbyte_tmp_tyt_export, stage: 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/
2022-07-15 21:21:58 destination > 2022-07-15 21:21:58 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:22:09 destination > 2022-07-15 21:22:09 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@4e642ee1
2022-07-15 21:22:09 destination > 2022-07-15 21:22:09 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:22:11 destination > 2022-07-15 21:22:11 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:22:12 destination > 2022-07-15 21:22:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream export
2022-07-15 21:22:12 destination > 2022-07-15 21:22:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream funnels: tmp table: _airbyte_tmp_gcd_funnels, stage: 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/
2022-07-15 21:22:12 destination > 2022-07-15 21:22:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:22:12 destination > 2022-07-15 21:22:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream funnels
2022-07-15 21:22:12 destination > 2022-07-15 21:22:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream revenue: tmp table: _airbyte_tmp_ali_revenue, stage: 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/
2022-07-15 21:22:13 destination > 2022-07-15 21:22:13 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:22:13 destination > 2022-07-15 21:22:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream revenue
2022-07-15 21:22:13 destination > 2022-07-15 21:22:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-15 21:24:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):327 - Source has no more messages, closing connection.
2022-07-15 21:24:41 destination > 2022-07-15 21:24:41 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-07-15 21:24:41 destination > 2022-07-15 21:24:41 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-07-15 21:24:41 destination > 2022-07-15 21:24:41 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):103 - Flushing all 0 current buffers (0 bytes in total)
2022-07-15 21:24:41 destination > 2022-07-15 21:24:41 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 3 streams
2022-07-15 21:24:41 destination > 2022-07-15 21:24:41 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream export of schema MIXPANEL_US into tmp table _airbyte_tmp_tyt_export to final table _airbyte_raw_export from stage path 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/ with 0 file(s) []
2022-07-15 21:24:42 destination > 2022-07-15 21:24:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream funnels of schema MIXPANEL_US into tmp table _airbyte_tmp_gcd_funnels to final table _airbyte_raw_funnels from stage path 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/ with 0 file(s) []
2022-07-15 21:24:42 destination > 2022-07-15 21:24:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream revenue of schema MIXPANEL_US into tmp table _airbyte_tmp_ali_revenue to final table _airbyte_raw_revenue from stage path 2022/07/15/21/66090E39-D5C2-4D85-9DB9-8814140F20C2/ with 0 file(s) []
2022-07-15 21:24:43 destination > 2022-07-15 21:24:43 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination.
2022-07-15 21:24:43 destination > 2022-07-15 21:24:43 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):216 - Executing finalization of tables.
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):218 - Finalizing tables in destination completed.
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):220 - Cleaning up destination started for 3 streams
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream export. schema MIXPANEL_US, tmp table name: _airbyte_tmp_tyt_export
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream export. schema MIXPANEL_US, stage: MIXPANEL_US_EXPORT
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream funnels. schema MIXPANEL_US, tmp table name: _airbyte_tmp_gcd_funnels
2022-07-15 21:24:44 destination > 2022-07-15 21:24:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream funnels. schema MIXPANEL_US, stage: MIXPANEL_US_FUNNELS
2022-07-15 21:24:45 destination > 2022-07-15 21:24:45 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream revenue. schema MIXPANEL_US, tmp table name: _airbyte_tmp_ali_revenue
2022-07-15 21:24:45 destination > 2022-07-15 21:24:45 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream revenue. schema MIXPANEL_US, stage: MIXPANEL_US_REVENUE
2022-07-15 21:24:45 destination > 2022-07-15 21:24:45 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):235 - Cleaning up destination completed.
2022-07-15 21:24:45 destination > 2022-07-15 21:24:45 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:24:48 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:173) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Source process exit with code 137. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:331) ~[io.airbyte-airbyte-workers-0.39.33-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: io.airbyte.workers.exception.WorkerException: Source process exit with code 137. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.33-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:329) ~[io.airbyte-airbyte-workers-0.39.33-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-07-15 21:24:48 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@29428d79[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657920091587,endTime=1657920288223,totalStats=io.airbyte.config.SyncStats@e3bcba9[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-07-15 21:24:48 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-15 21:24:48 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-07-15 21:24:48 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:24:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@3dbf3488[standardSyncSummary=io.airbyte.config.StandardSyncSummary@78bdbd5b[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657920091587,endTime=1657920288223,totalStats=io.airbyte.config.SyncStats@e3bcba9[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7588952b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@498f074d[stream=io.airbyte.protocol.models.AirbyteStream@d507180[name=export,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"os":{"type":["null","string"]},"to":{"type":["null","string"]},"URL":{"type":["null","string"]},"area":{"type":["null","string"]},"args":{"type":["null","string"]},"city":{"type":["null","string"]},"date":{"type":["null","string"]},"from":{"type":["null","string"]},"host":{"type":["null","string"]},"page":{"type":["null","string"]},"rate":{"type":["null","string"]},"size":{"type":["null","string"]},"step":{"type":["null","string"]},"time":{"type":["null","string"],"format":"date-time"},"type":{"type":["null","string"]},"wifi":{"type":["null","string"]},"Error":{"type":["null","string"]},"brand":{"type":["null","string"]},"break":{"type":["null","string"]},"dates":{"type":["null","string"]},"email":{"type":["null","string"]},"event":{"type":["null","string"]},"model":{"type":["null","string"]},"nurse":{"type":["null","string"]},"radio":{"type":["null","string"]},"roles":{"type":["null","string"]},"scope":{"type":["null","string"]},"state":{"type":["null","string"]},"times":{"type":["null","string"]},"title":{"type":["null","string"]},"value":{"type":["null","string"]},"venue":{"type":["null","string"]},"Source":{"type":["null","string"]},"_email":{"type":["null","string"]},"_error":{"type":["null","string"]},"amount":{"type":["null","string"]},"busser":{"type":["null","string"]},"device":{"type":["null","string"]},"job_id":{"type":["null","string"]},"labels":{"type":["null","array"],"items":{"type":["null","string"]}},"loader":{"type":["null","string"]},"mp_lib":{"type":["null","string"]},"option":{"type":["null","string"]},"region":{"type":["null","string"]},"roleId":{"type":["null","string"]},"screen":{"type":["null","string"]},"server":{"type":["null","string"]},"barista":{"type":["null","string"]},"browser":{"type":["null","string"]},"carrier":{"type":["null","string"]},"checked":{"type":["null","string"]},"cleaner":{"type":["null","string"]},"dataset":{"type":["null","string"]},"feature":{"type":["null","string"]},"has_nfc":{"type":["null","string"]},"hostess":{"type":["null","string"]},"role_id":{"type":["null","string"]},"shiftId":{"type":["null","string"]},"steward":{"type":["null","string"]},"user_id":{"type":["null","string"]},"venueId":{"type":["null","string"]},"version":{"type":["null","string"]},"workers":{"type":["null","string"]},"add_role":{"type":["null","string"]},"bar_back":{"type":["null","string"]},"bookable":{"type":["null","string"]},"creation":{"type":["null","string"]},"decision":{"type":["null","string"]},"duration":{"type":["null","string"]},"end_time":{"type":["null","string"]},"features":{"type":["null","string"]},"referrer":{"type":["null","string"]},"skill_id":{"type":["null","string"]},"template":{"type":["null","string"]},"workerId":{"type":["null","string"]},"Case Type":{"type":["null","string"]},"add_dates":{"type":["null","string"]},"add_roles":{"type":["null","string"]},"assembler":{"type":["null","string"]},"banner_id":{"type":["null","string"]},"bar_staff":{"type":["null","string"]},"client_id":{"type":["null","string"]},"device_id":{"type":["null","string"]},"edit_rate":{"type":["null","string"]},"essential":{"type":["null","string"]},"head_chef":{"type":["null","string"]},"interview":{"type":["null","string"]},"lead_chef":{"type":["null","string"]},"line_cook":{"type":["null","string"]},"prep_cook":{"type":["null","string"]},"role_name":{"type":["null","string"]},"selection":{"type":["null","string"]},"sorted_by":{"type":["null","string"]},"sous_chef":{"type":["null","string"]},"worker_id":{"type":["null","string"]},"cancel_job":{"type":["null","string"]},"create_job":{"type":["null","string"]},"dishwasher":{"type":["null","string"]},"duration_s":{"type":["null","string"]},"event_name":{"type":["null","string"]},"friday_day":{"type":["null","string"]},"job_viewed":{"type":["null","string"]},"listing_id":{"type":["null","string"]},"monday_day":{"type":["null","string"]},"mp_keyword":{"type":["null","string"]},"origin_end":{"type":["null","string"]},"os_version":{"type":["null","string"]},"paid break":{"type":["null","string"]},"screen_dpi":{"type":["null","string"]},"skill_name":{"type":["null","string"]},"start_time":{"type":["null","string"]},"sunday_day":{"type":["null","string"]},"supervisor":{"type":["null","string"]},"tab_select":{"type":["null","string"]},"time_stamp":{"type":["null","string"]},"venue_area":{"type":["null","string"]},"Destination":{"type":["null","string"]},"app_release":{"type":["null","string"]},"browse_page":{"type":["null","string"]},"care_worker":{"type":["null","string"]},"client_name":{"type":["null","string"]},"commis_chef":{"type":["null","string"]},"current_url":{"type":["null","string"]},"default_tab":{"type":["null","string"]},"distinct_id":{"type":["null","string"]},"event_count":{"type":["null","string"]},"housekeeper":{"type":["null","string"]},"industry_id":{"type":["null","string"]},"lib_version":{"type":["null","string"]},"platform_id":{"type":["null","string"]},"reason_text":{"type":["null","string"]},"team_leader":{"type":["null","string"]},"tuesday_day":{"type":["null","string"]},"Variant name":{"type":["null","string"]},"_destination":{"type":["null","string"]},"backend_host":{"type":["null","string"]},"filter_dates":{"type":["null","string"]},"filter_roles":{"type":["null","string"]},"friday_early":{"type":["null","string"]},"friday_night":{"type":["null","string"]},"get_verified":{"type":["null","string"]},"housekeeping":{"type":["null","string"]},"manufacturer":{"type":["null","string"]},"minimum_rate":{"type":["null","string"]},"monday_early":{"type":["null","string"]},"monday_night":{"type":["null","string"]},"origin_start":{"type":["null","string"]},"profile_type":{"type":["null","string"]},"receptionist":{"type":["null","string"]},"role_workers":{"type":["null","string"]},"saturday_day":{"type":["null","string"]},"screen_width":{"type":["null","string"]},"student_loan":{"type":["null","string"]},"sunday_early":{"type":["null","string"]},"sunday_night":{"type":["null","string"]},"thursday_day":{"type":["null","string"]},"unread_count":{"type":["null","string"]},"Case Category":{"type":["null","string"]},"document_name":{"type":["null","string"]},"employer_gdpr":{"type":["null","string"]},"general_staff":{"type":["null","string"]},"has_telephone":{"type":["null","string"]},"industry_name":{"type":["null","string"]},"overseas_work":{"type":["null","string"]},"picker_packer":{"type":["null","string"]},"place_in_list":{"type":["null","string"]},"screen_height":{"type":["null","string"]},"search_engine":{"type":["null","string"]},"select_shifts":{"type":["null","string"]},"shelf_stacker":{"type":["null","string"]},"tuesday_early":{"type":["null","string"]},"tuesday_night":{"type":["null","string"]},"uniform_image":{"type":["null","string"]},"waiting_staff":{"type":["null","string"]},"wednesday_day":{"type":["null","string"]},"ViewController":{"type":["null","string"]},"care_assistant":{"type":["null","string"]},"check_out_type":{"type":["null","string"]},"chef_de_partie":{"type":["null","string"]},"festival_labor":{"type":["null","string"]},"festival_staff":{"type":["null","string"]},"form_i9_passed":{"type":["null","string"]},"junior_manager":{"type":["null","string"]},"kitchen_porter":{"type":["null","string"]},"legal_document":{"type":["null","string"]},"remove_network":{"type":["null","string"]},"saturday_early":{"type":["null","string"]},"saturday_night":{"type":["null","string"]},"sorting_method":{"type":["null","string"]},"thursday_early":{"type":["null","string"]},"thursday_night":{"type":["null","string"]},"type_of_action":{"type":["null","string"]},"Experiment name":{"type":["null","string"]},"Shift Reference":{"type":["null","string"]},"browser_version":{"type":["null","string"]},"delivery_driver":{"type":["null","string"]},"door_supervisor":{"type":["null","string"]},"events_security":{"type":["null","string"]},"hiring_capacity":{"type":["null","string"]},"kitchen_manager":{"type":["null","string"]},"mp_country_code":{"type":["null","string"]},"sampling_factor":{"type":["null","integer"]},"verified_status":{"type":["null","string"]},"wednesday_early":{"type":["null","string"]},"wednesday_night":{"type":["null","string"]},"worker_verified":{"type":["null","string"]},"app_build_number":{"type":["null","string"]},"company_creation":{"type":["null","string"]},"event_technician":{"type":["null","string"]},"fm_general_labor":{"type":["null","string"]},"impersonating_id":{"type":["null","string"]},"initial_referrer":{"type":["null","string"]},"machine_operator":{"type":["null","string"]},"referring_domain":{"type":["null","string"]},"selection_change":{"type":["null","string"]},"ae_crashed_reason":{"type":["null","string"]},"ae_session_length":{"type":["null","string"]},"bluetooth_enabled":{"type":["null","string"]},"bluetooth_version":{"type":["null","string"]},"braze_external_id":{"type":["null","string"]},"casual_technician":{"type":["null","string"]},"edit_availability":{"type":["null","string"]},"experiment_home_1":{"type":["null","string"]},"forklift_operator":{"type":["null","string"]},"health_and_safety":{"type":["null","string"]},"main_profile_type":{"type":["null","string"]},"notification_type":{"type":["null","string"]},"numSelectedSkills":{"type":["null","string"]},"senior_technician":{"type":["null","string"]},"verification_page":{"type":["null","string"]},"app_version_string":{"type":["null","string"]},"medical_conditions":{"type":["null","string"]},"motorcycle_courier":{"type":["null","string"]},"worker_interviewed":{"type":["null","string"]},"date_filter_applied":{"type":["null","string"]},"days_since_verified":{"type":["null","string"]},"financial_situation":{"type":["null","string"]},"food_prep_assistant":{"type":["null","string"]},"role_filter_applied":{"type":["null","string"]},"senior_staff_member":{"type":["null","string"]},"stockroom_assistant":{"type":["null","string"]},"warehouse_operative":{"type":["null","string"]},"PlayServices.Version":{"type":["null","string"]},"customer_service_rep":{"type":["null","string"]},"filter_location_unit":{"type":["null","string"]},"google_play_services":{"type":["null","string"]},"overtime pay consent":{"type":["null","string"]},"apprentice_technician":{"type":["null","string"]},"bookable_individually":{"type":["null","string"]},"collection_specialist":{"type":["null","string"]},"data_entry_specialist":{"type":["null","string"]},"jobs_and roles_passed":{"type":["null","string"]},"jobs_and_roles_passed":{"type":["null","string"]},"notification_category":{"type":["null","string"]},"numSelectedHardSkills":{"type":["null","string"]},"ae_first_app_open_date":{"type":["null","string"]},"filter_location_radius":{"type":["null","string"]},"jobs_viewed_in_session":{"type":["null","string"]},"online_order_assistant":{"type":["null","string"]},"allow_individual_shifts":{"type":["null","string"]},"employer_filter_applied":{"type":["null","string"]},"location_filter_applied":{"type":["null","string"]},"replenishment_assistant":{"type":["null","string"]},"written_reason_provided":{"type":["null","string"]},"administrative_assistant":{"type":["null","string"]},"filter_location_latitude":{"type":["null","string"]},"industrial_general_labor":{"type":["null","string"]},"initial_referring_domain":{"type":["null","string"]},"number_of_verified_roles":{"type":["null","string"]},"back_of_house_team_member":{"type":["null","string"]},"employer_account_creation":{"type":["null","string"]},"filter_location_longitude":{"type":["null","string"]},"food_production_operative":{"type":["null","string"]},"hospitality_general_labor":{"type":["null","string"]},"self_service_verification":{"type":["null","string"]},"venue_access_instructions":{"type":["null","string"]},"lead_generation_specialist":{"type":["null","string"]},"preselected_reason_provided":{"type":["null","string"]},"same shift times for all days":{"type":["null","string"]},"videos_and_assessments_passed":{"type":["null","string"]},"agree to t&c and privacy policy":{"type":["null","string"]},"worker_preferences_stored_hours":{"type":["null","string"]},"worker_preferences_stored_roles":{"type":["null","string"]},"allow individual booking of shifts":{"type":["null","string"]},"worker_preferences_stored_location":{"type":["null","string"]},"conditional_job_offer_agreement_passed":{"type":["null","string"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[time],sourceDefinedPrimaryKey=[],namespace=MIXPANEL_US,additionalProperties={}],syncMode=incremental,cursorField=[time],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@18924214[stream=io.airbyte.protocol.models.AirbyteStream@2902bde0[name=funnels,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"date":{"type":["null","string"],"format":"date"},"name":{"type":["null","string"]},"steps":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"goal":{"type":["null","string"]},"count":{"type":["null","integer"]},"event":{"type":["null","string"]},"avg_time":{"type":["null","number"],"multipleOf":1.0E-20},"selector":{"type":["null","string"]},"step_label":{"type":["null","string"]},"session_event":{"type":["null","string"]},"selector_params":{"type":["null","object"],"properties":{"step_label":{"type":["null","string"]}},"additionalProperties":true},"step_conv_ratio":{"type":["null","number"],"multipleOf":1.0E-20},"overall_conv_ratio":{"type":["null","number"],"multipleOf":1.0E-20},"avg_time_from_start":{"type":["null","number"],"multipleOf":1.0E-20},"time_buckets_from_prev":{"type":["null","object"],"properties":{"lower":{"type":["null","integer"]},"higher":{"type":["null","integer"]},"buckets":{"type":["null","array"],"items":{"type":"integer"}}},"additionalProperties":false},"time_buckets_from_start":{"type":["null","object"],"properties":{"lower":{"type":["null","integer"]},"higher":{"type":["null","integer"]},"buckets":{"type":["null","array"],"items":{"type":"integer"}}},"additionalProperties":false}},"additionalProperties":true}},"analysis":{"type":["null","object"],"properties":{"steps":{"type":["null","integer"]},"worst":{"type":["null","integer"]},"completion":{"type":["null","integer"]},"starting_amount":{"type":["null","integer"]}},"additionalProperties":false},"datetime":{"type":["null","string"],"format":"date-time"},"funnel_id":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date],sourceDefinedPrimaryKey=[[funnel_id], [date]],namespace=MIXPANEL_US,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[funnel_id], [date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@180662e2[stream=io.airbyte.protocol.models.AirbyteStream@1654dc13[name=revenue,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"date":{"type":["null","string"],"format":"date"},"count":{"type":["null","integer"]},"amount":{"type":["null","number"],"multipleOf":1.0E-20},"datetime":{"type":["null","string"],"format":"date-time"},"paid_count":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date],sourceDefinedPrimaryKey=[[date]],namespace=MIXPANEL_US,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[date]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@1cdcbe2f[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@200dede9[additionalProperties={attemptNumber=1, jobId=2626}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	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: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:331)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 137. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136)
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:329)
	... 4 more
,retryable=<null>,timestamp=1657920281069]]]
2022-07-15 21:24:48 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-15 21:24:51 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-15 21:24:51 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-15 21:24:52 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/2/logs.log
2022-07-15 21:24:52 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:24:52 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:24:52 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:24:54 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:24:54 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/2 --log-driver none --name source-mixpanel-check-2626-2-yeyry --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=2 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-15 21:24:54 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:25:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-15 21:25:07 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:25:07 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/2/logs.log
2022-07-15 21:25:07 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:25:07 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:25:07 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:25:07 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:25:07 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:25:07 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/2 --log-driver none --name destination-snowflake-check-2626-2-jatsg --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=2 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-15 21:25:10 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:25:10 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-15 21:25:10 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-15 21:25:10 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-15 21:25:10 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:25:10 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 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-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 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-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 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-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 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-15 21:25:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:12 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-15 21:25:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:13 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:25:15 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:15 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3b705be7
2022-07-15 21:25:15 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:15 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:25:15 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:15 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:25:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:16 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-15 21:25:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:25:16 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-15 21:25:17 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:25:18 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2626/2/logs.log
2022-07-15 21:25:18 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:25:18 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 2626 attempt id: 2
2022-07-15 21:25:18 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.export=incremental - append, null.funnels=incremental - append, null.revenue=incremental - append}
2022-07-15 21:25:18 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-15 21:25:18 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:25:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:25:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:25:18 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:25:18 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/2 --log-driver none --name destination-snowflake-write-2626-2-jddvs --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_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=2 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-15 21:25:18 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:25:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:25:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:25:18 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2626
2022-07-15 21:25:18 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2626/2 --log-driver none --name source-mixpanel-read-2626-2-fjyfh --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_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=2 -e AIRBYTE_VERSION=0.39.33-alpha -e WORKER_JOB_ID=2626 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json
2022-07-15 21:25:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-15 21:25:18 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-15 21:25:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-15 21:25:19 source > Starting syncing SourceMixpanel
2022-07-15 21:25:19 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:25:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:25:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:25:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:25:19 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:25:19 source > Using start_date: 2022-07-01, end_date: 2022-07-15
2022-07-15 21:25:19 source > Syncing stream: export 
2022-07-15 21:25:19 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:25:20 destination > 2022-07-15 21:25:20 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-15 21:25:20 destination > 2022-07-15 21:25:20 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:25:21 destination > 2022-07-15 21:25:20 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:25:21 destination > 2022-07-15 21:25:21 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-15 21:25:21 destination > 2022-07-15 21:25:21 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-15 21:25:21 destination > 2022-07-15 21:25:21 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-15 21:25:21 destination > 2022-07-15 21:25:21 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-15 21:25:21 destination > 2022-07-15 21:25:21 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-15 21:25:21 destination > 2022-07-15 21:25:21 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-15 21:25:22 destination > 2022-07-15 21:25:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_gtv_export, outputTableName=_airbyte_raw_export, syncMode=append}
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_qdm_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append}
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=MIXPANEL_US, outputSchemaName=MIXPANEL_US, tmpTableName=_airbyte_tmp_pkf_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append}
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 3 streams
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream export: tmp table: _airbyte_tmp_gtv_export, stage: 2022/07/15/21/2C6E9507-DC0B-452A-BF2F-6665A044952D/
2022-07-15 21:25:22 destination > 2022-07-15 21:25:22 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:25:26 destination > 2022-07-15 21:25:26 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@29ebbdf4
2022-07-15 21:25:26 destination > 2022-07-15 21:25:26 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:25:26 destination > 2022-07-15 21:25:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:25:27 destination > 2022-07-15 21:25:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream export
2022-07-15 21:25:27 destination > 2022-07-15 21:25:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream funnels: tmp table: _airbyte_tmp_qdm_funnels, stage: 2022/07/15/21/2C6E9507-DC0B-452A-BF2F-6665A044952D/
2022-07-15 21:25:27 destination > 2022-07-15 21:25:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:25:28 destination > 2022-07-15 21:25:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream funnels
2022-07-15 21:25:28 destination > 2022-07-15 21:25:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_US stream revenue: tmp table: _airbyte_tmp_pkf_revenue, stage: 2022/07/15/21/2C6E9507-DC0B-452A-BF2F-6665A044952D/
2022-07-15 21:25:28 destination > 2022-07-15 21:25:28 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:25:29 destination > 2022-07-15 21:25:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_US stream revenue
2022-07-15 21:25:29 destination > 2022-07-15 21:25:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-15 21:38:55 destination > 2022-07-15 21:34:02 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=52s260ms806µs775ns).
2022-07-15 21:43:33 destination > 2022-07-15 21:38:28 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=9m48s181ms111µs316ns).