2022-07-15 21:02:24 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:02:24 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-15 21:02:25 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/0/logs.log
2022-07-15 21:02:25 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:02:25 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:02:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:02:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:02:25 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:02:25 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/0 --log-driver none --name source-mixpanel-check-2625-0-gjhgi --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=2625 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-15 21:02:38 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-15 21:02:39 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:02:40 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/0/logs.log
2022-07-15 21:02:40 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:02:40 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:02:40 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:02:40 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:02:40 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:02:40 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/0 --log-driver none --name destination-snowflake-check-2625-0-wznfw --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=2625 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-15 21:02:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:02:55 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:02:55 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:02:55 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:02:55 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:02:57 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:03:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:06 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-15 21:03:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:07 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:03:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:07 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-15 21:03:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:07 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:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:08 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:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:08 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:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:08 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:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03: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:03:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:09 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-15 21:03:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:14 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:28 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3b705be7
2022-07-15 21:03:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:28 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:03:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:03:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:31 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-15 21:03:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:03:32 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-15 21:03:34 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:03:35 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/0/logs.log
2022-07-15 21:03:35 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:03:36 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 2625 attempt id: 0
2022-07-15 21:03:36 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:03:36 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-15 21:03:36 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:03:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:03:36 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:03:37 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:03:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/0 --log-driver none --name destination-snowflake-write-2625-0-zbvdy --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=2625 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-15 21:03:37 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:03:37 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:03:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:03:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:03:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/0 --log-driver none --name source-mixpanel-read-2625-0-fzilp --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=2625 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json
2022-07-15 21:03:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-15 21:03:38 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-15 21:03:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-15 21:03:46 source > Starting syncing SourceMixpanel
2022-07-15 21:03:46 source > Using start_date: 2022-07-01, end_date: 2022-07-15
2022-07-15 21:03:46 source > Syncing stream: export 
2022-07-15 21:03:48 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:03:48 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:03:48 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:03:48 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:03:48 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:03:50 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:04:08 destination > 2022-07-15 21:04:07 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-15 21:04:08 destination > 2022-07-15 21:04:08 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:04:08 destination > 2022-07-15 21:04:08 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:04:08 destination > 2022-07-15 21:04:08 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:04:10 destination > 2022-07-15 21:04:10 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:04:10 destination > 2022-07-15 21:04:10 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:04:10 destination > 2022-07-15 21:04:10 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:04:11 destination > 2022-07-15 21:04:10 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:04:12 destination > 2022-07-15 21:04:12 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-15 21:04:22 destination > 2022-07-15 21:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_mlw_export, outputTableName=_airbyte_raw_export, syncMode=append}
2022-07-15 21:04:22 destination > 2022-07-15 21:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_faf_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append}
2022-07-15 21:04:22 destination > 2022-07-15 21:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_gpr_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append}
2022-07-15 21:04:25 destination > 2022-07-15 21:04:25 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-15 21:04:25 destination > 2022-07-15 21:04:25 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 3 streams
2022-07-15 21:04:25 destination > 2022-07-15 21:04:25 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream export: tmp table: _airbyte_tmp_mlw_export, stage: 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/
2022-07-15 21:04:25 destination > 2022-07-15 21:04:25 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:04:51 destination > 2022-07-15 21:04:51 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@254449bb
2022-07-15 21:04:51 destination > 2022-07-15 21:04:51 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:04:53 destination > 2022-07-15 21:04:53 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:04:56 destination > 2022-07-15 21:04:56 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream export
2022-07-15 21:04:56 destination > 2022-07-15 21:04:56 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream funnels: tmp table: _airbyte_tmp_faf_funnels, stage: 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/
2022-07-15 21:04:57 destination > 2022-07-15 21:04:57 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:04:58 destination > 2022-07-15 21:04:58 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream funnels
2022-07-15 21:04:58 destination > 2022-07-15 21:04:58 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream revenue: tmp table: _airbyte_tmp_gpr_revenue, stage: 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/
2022-07-15 21:04:58 destination > 2022-07-15 21:04:58 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:04:59 destination > 2022-07-15 21:04:59 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream revenue
2022-07-15 21:04:59 destination > 2022-07-15 21:04:59 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-15 21:07:03 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation...
2022-07-15 21:07:03 INFO i.a.w.g.DefaultReplicationWorker(cancel):443 - Cancelling replication worker...
2022-07-15 21:07:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):327 - Source has no more messages, closing connection.
2022-07-15 21:07:08 destination > 2022-07-15 21:07:07 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-07-15 21:07:08 destination > 2022-07-15 21:07:07 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-07-15 21:07:08 destination > 2022-07-15 21:07:08 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):103 - Flushing all 0 current buffers (0 bytes in total)
2022-07-15 21:07:08 destination > 2022-07-15 21:07:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 3 streams
2022-07-15 21:07:08 destination > 2022-07-15 21:07:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream export of schema MIXPANEL_UK into tmp table _airbyte_tmp_mlw_export to final table _airbyte_raw_export from stage path 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/ with 0 file(s) []
2022-07-15 21:07:09 destination > 2022-07-15 21:07:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream funnels of schema MIXPANEL_UK into tmp table _airbyte_tmp_faf_funnels to final table _airbyte_raw_funnels from stage path 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/ with 0 file(s) []
2022-07-15 21:07:09 destination > 2022-07-15 21:07:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream revenue of schema MIXPANEL_UK into tmp table _airbyte_tmp_gpr_revenue to final table _airbyte_raw_revenue from stage path 2022/07/15/21/83AF40F0-6F9C-40CA-AA0A-41CA24065DBF/ with 0 file(s) []
2022-07-15 21:07:10 destination > 2022-07-15 21:07:10 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination.
2022-07-15 21:07:10 destination > 2022-07-15 21:07:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):216 - Executing finalization of tables.
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):218 - Finalizing tables in destination completed.
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):220 - Cleaning up destination started for 3 streams
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream export. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_mlw_export
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream export. schema MIXPANEL_UK, stage: MIXPANEL_UK_EXPORT
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream funnels. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_faf_funnels
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream funnels. schema MIXPANEL_UK, stage: MIXPANEL_UK_FUNNELS
2022-07-15 21:07:11 destination > 2022-07-15 21:07:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream revenue. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_gpr_revenue
2022-07-15 21:07:12 destination > 2022-07-15 21:07:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream revenue. schema MIXPANEL_UK, stage: MIXPANEL_UK_REVENUE
2022-07-15 21:07:12 destination > 2022-07-15 21:07:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):235 - Cleaning up destination completed.
2022-07-15 21:07:12 destination > 2022-07-15 21:07:12 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:07:13 INFO i.a.w.g.DefaultReplicationWorker(cancel):451 - Cancelling destination...
2022-07-15 21:07:13 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-07-15 21:07:13 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-07-15 21:07:15 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) [?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 143. 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) [?:?]
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:07:15 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6b8ff0[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1657919016288,endTime=1657919235719,totalStats=io.airbyte.config.SyncStats@65e975f0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-07-15 21:07:15 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-15 21:07:15 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-07-15 21:07:15 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-07-15 21:07:15 INFO i.a.w.g.DefaultReplicationWorker(cancel):458 - Cancelling source...
2022-07-15 21:07:15 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-07-15 21:07:15 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-07-15 21:07:15 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-07-15 21:07:15 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread...
2022-07-15 21:07:15 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future...
2022-07-15 21:07:15 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-15 21:07:15 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-15 21:07:15 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:07:15 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@2a3c5db[standardSyncSummary=io.airbyte.config.StandardSyncSummary@47a15beb[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1657919016288,endTime=1657919235719,totalStats=io.airbyte.config.SyncStats@65e975f0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@125a9b42[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@762c5a08[stream=io.airbyte.protocol.models.AirbyteStream@6a3dc40b[name=export,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"c":{"type":["null","string"]},"id":{"type":["null","string"]},"os":{"type":["null","string"]},"to":{"type":["null","string"]},"URL":{"type":["null","string"]},"app":{"type":["null","string"]},"area":{"type":["null","string"]},"args":{"type":["null","string"]},"city":{"type":["null","string"]},"code":{"type":["null","string"]},"date":{"type":["null","string"]},"from":{"type":["null","string"]},"page":{"type":["null","string"]},"rate":{"type":["null","string"]},"size":{"type":["null","string"]},"time":{"type":["null","string"],"format":"date-time"},"type":{"type":["null","string"]},"wifi":{"type":["null","string"]},"_wifi":{"type":["null","string"]},"admin":{"type":["null","string"]},"brand":{"type":["null","string"]},"break":{"type":["null","string"]},"dates":{"type":["null","string"]},"email":{"type":["null","string"]},"error":{"type":["null","string"]},"event":{"type":["null","string"]},"model":{"type":["null","string"]},"nudge":{"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"]},"539354":{"type":["null","string"]},"541357":{"type":["null","string"]},"541399":{"type":["null","string"]},"546665":{"type":["null","string"]},"547254":{"type":["null","string"]},"548512":{"type":["null","string"]},"548513":{"type":["null","string"]},"549154":{"type":["null","string"]},"549155":{"type":["null","string"]},"549268":{"type":["null","string"]},"549677":{"type":["null","string"]},"549679":{"type":["null","string"]},"550377":{"type":["null","string"]},"550378":{"type":["null","string"]},"550380":{"type":["null","string"]},"550931":{"type":["null","string"]},"551061":{"type":["null","string"]},"551073":{"type":["null","string"]},"552730":{"type":["null","string"]},"552956":{"type":["null","string"]},"553005":{"type":["null","string"]},"553768":{"type":["null","string"]},"553777":{"type":["null","string"]},"554031":{"type":["null","string"]},"554045":{"type":["null","string"]},"554047":{"type":["null","string"]},"554320":{"type":["null","string"]},"554831":{"type":["null","string"]},"554947":{"type":["null","string"]},"554956":{"type":["null","string"]},"554961":{"type":["null","string"]},"554963":{"type":["null","string"]},"554975":{"type":["null","string"]},"555345":{"type":["null","string"]},"555654":{"type":["null","string"]},"555670":{"type":["null","string"]},"555672":{"type":["null","string"]},"555675":{"type":["null","string"]},"555709":{"type":["null","string"]},"555905":{"type":["null","string"]},"556001":{"type":["null","string"]},"556015":{"type":["null","string"]},"557231":{"type":["null","string"]},"557314":{"type":["null","string"]},"557544":{"type":["null","string"]},"557787":{"type":["null","string"]},"557848":{"type":["null","string"]},"558074":{"type":["null","string"]},"558351":{"type":["null","string"]},"558364":{"type":["null","string"]},"558614":{"type":["null","string"]},"558616":{"type":["null","string"]},"558754":{"type":["null","string"]},"558756":{"type":["null","string"]},"558973":{"type":["null","string"]},"559056":{"type":["null","string"]},"559057":{"type":["null","string"]},"559238":{"type":["null","string"]},"559263":{"type":["null","string"]},"559346":{"type":["null","string"]},"559724":{"type":["null","string"]},"559725":{"type":["null","string"]},"559726":{"type":["null","string"]},"559908":{"type":["null","string"]},"559932":{"type":["null","string"]},"559967":{"type":["null","string"]},"559973":{"type":["null","string"]},"560130":{"type":["null","string"]},"560136":{"type":["null","string"]},"560142":{"type":["null","string"]},"560172":{"type":["null","string"]},"560200":{"type":["null","string"]},"560222":{"type":["null","string"]},"560223":{"type":["null","string"]},"560241":{"type":["null","string"]},"560354":{"type":["null","string"]},"560367":{"type":["null","string"]},"560835":{"type":["null","string"]},"560837":{"type":["null","string"]},"561330":{"type":["null","string"]},"561379":{"type":["null","string"]},"561722":{"type":["null","string"]},"561826":{"type":["null","string"]},"561830":{"type":["null","string"]},"561834":{"type":["null","string"]},"561841":{"type":["null","string"]},"561843":{"type":["null","string"]},"561906":{"type":["null","string"]},"561949":{"type":["null","string"]},"562030":{"type":["null","string"]},"562069":{"type":["null","string"]},"562129":{"type":["null","string"]},"562132":{"type":["null","string"]},"562199":{"type":["null","string"]},"562206":{"type":["null","string"]},"562244":{"type":["null","string"]},"562445":{"type":["null","string"]},"562449":{"type":["null","string"]},"562510":{"type":["null","string"]},"562708":{"type":["null","string"]},"562800":{"type":["null","string"]},"562802":{"type":["null","string"]},"562920":{"type":["null","string"]},"562942":{"type":["null","string"]},"562994":{"type":["null","string"]},"563014":{"type":["null","string"]},"563043":{"type":["null","string"]},"563226":{"type":["null","string"]},"563228":{"type":["null","string"]},"563329":{"type":["null","string"]},"563330":{"type":["null","string"]},"563435":{"type":["null","string"]},"564055":{"type":["null","string"]},"564080":{"type":["null","string"]},"564215":{"type":["null","string"]},"564286":{"type":["null","string"]},"564390":{"type":["null","string"]},"564413":{"type":["null","string"]},"564494":{"type":["null","string"]},"564630":{"type":["null","string"]},"564639":{"type":["null","string"]},"564645":{"type":["null","string"]},"564682":{"type":["null","string"]},"564704":{"type":["null","string"]},"564721":{"type":["null","string"]},"564732":{"type":["null","string"]},"564741":{"type":["null","string"]},"565318":{"type":["null","string"]},"565319":{"type":["null","string"]},"565461":{"type":["null","string"]},"565470":{"type":["null","string"]},"565634":{"type":["null","string"]},"565672":{"type":["null","string"]},"566029":{"type":["null","string"]},"566146":{"type":["null","string"]},"566227":{"type":["null","string"]},"566318":{"type":["null","string"]},"566409":{"type":["null","string"]},"566441":{"type":["null","string"]},"566448":{"type":["null","string"]},"566450":{"type":["null","string"]},"566451":{"type":["null","string"]},"566626":{"type":["null","string"]},"566655":{"type":["null","string"]},"566715":{"type":["null","string"]},"566718":{"type":["null","string"]},"566829":{"type":["null","string"]},"566972":{"type":["null","string"]},"566994":{"type":["null","string"]},"567032":{"type":["null","string"]},"567049":{"type":["null","string"]},"567699":{"type":["null","string"]},"567784":{"type":["null","string"]},"567996":{"type":["null","string"]},"568040":{"type":["null","string"]},"568061":{"type":["null","string"]},"568062":{"type":["null","string"]},"568085":{"type":["null","string"]},"568469":{"type":["null","string"]},"568499":{"type":["null","string"]},"568501":{"type":["null","string"]},"568751":{"type":["null","string"]},"568754":{"type":["null","string"]},"568769":{"type":["null","string"]},"568926":{"type":["null","string"]},"569085":{"type":["null","string"]},"569221":{"type":["null","string"]},"569571":{"type":["null","string"]},"569584":{"type":["null","string"]},"569661":{"type":["null","string"]},"569671":{"type":["null","string"]},"569672":{"type":["null","string"]},"569692":{"type":["null","string"]},"569693":{"type":["null","string"]},"569694":{"type":["null","string"]},"569700":{"type":["null","string"]},"569701":{"type":["null","string"]},"569727":{"type":["null","string"]},"569736":{"type":["null","string"]},"569795":{"type":["null","string"]},"569982":{"type":["null","string"]},"570036":{"type":["null","string"]},"570042":{"type":["null","string"]},"570043":{"type":["null","string"]},"570264":{"type":["null","string"]},"570308":{"type":["null","string"]},"570427":{"type":["null","string"]},"570428":{"type":["null","string"]},"570483":{"type":["null","string"]},"570521":{"type":["null","string"]},"570528":{"type":["null","string"]},"570698":{"type":["null","string"]},"570836":{"type":["null","string"]},"570886":{"type":["null","string"]},"570924":{"type":["null","string"]},"571086":{"type":["null","string"]},"571369":{"type":["null","string"]},"571443":{"type":["null","string"]},"571592":{"type":["null","string"]},"571676":{"type":["null","string"]},"571721":{"type":["null","string"]},"571775":{"type":["null","string"]},"571992":{"type":["null","string"]},"572221":{"type":["null","string"]},"572222":{"type":["null","string"]},"572318":{"type":["null","string"]},"572321":{"type":["null","string"]},"572346":{"type":["null","string"]},"572483":{"type":["null","string"]},"572714":{"type":["null","string"]},"572754":{"type":["null","string"]},"572762":{"type":["null","string"]},"572763":{"type":["null","string"]},"572772":{"type":["null","string"]},"572778":{"type":["null","string"]},"572804":{"type":["null","string"]},"572938":{"type":["null","string"]},"573083":{"type":["null","string"]},"573150":{"type":["null","string"]},"573460":{"type":["null","string"]},"573486":{"type":["null","string"]},"573503":{"type":["null","string"]},"573530":{"type":["null","string"]},"573654":{"type":["null","string"]},"573684":{"type":["null","string"]},"573835":{"type":["null","string"]},"574303":{"type":["null","string"]},"574344":{"type":["null","string"]},"574395":{"type":["null","string"]},"574499":{"type":["null","string"]},"574559":{"type":["null","string"]},"574595":{"type":["null","string"]},"574652":{"type":["null","string"]},"574671":{"type":["null","string"]},"574673":{"type":["null","string"]},"574886":{"type":["null","string"]},"574949":{"type":["null","string"]},"575101":{"type":["null","string"]},"575188":{"type":["null","string"]},"575287":{"type":["null","string"]},"575541":{"type":["null","string"]},"575643":{"type":["null","string"]},"576086":{"type":["null","string"]},"576116":{"type":["null","string"]},"576214":{"type":["null","string"]},"576291":{"type":["null","string"]},"576335":{"type":["null","string"]},"576364":{"type":["null","string"]},"576459":{"type":["null","string"]},"576508":{"type":["null","string"]},"576687":{"type":["null","string"]},"576853":{"type":["null","string"]},"576854":{"type":["null","string"]},"576857":{"type":["null","string"]},"576913":{"type":["null","string"]},"576964":{"type":["null","string"]},"577397":{"type":["null","string"]},"578232":{"type":["null","string"]},"579309":{"type":["null","string"]},"579310":{"type":["null","string"]},"579325":{"type":["null","string"]},"579496":{"type":["null","string"]},"579748":{"type":["null","string"]},"580150":{"type":["null","string"]},"580151":{"type":["null","string"]},"580414":{"type":["null","string"]},"580422":{"type":["null","string"]},"580526":{"type":["null","string"]},"580530":{"type":["null","string"]},"580534":{"type":["null","string"]},"580573":{"type":["null","string"]},"580582":{"type":["null","string"]},"580584":{"type":["null","string"]},"580588":{"type":["null","string"]},"580589":{"type":["null","string"]},"580590":{"type":["null","string"]},"580948":{"type":["null","string"]},"580968":{"type":["null","string"]},"581027":{"type":["null","string"]},"581270":{"type":["null","string"]},"581273":{"type":["null","string"]},"581279":{"type":["null","string"]},"581284":{"type":["null","string"]},"581477":{"type":["null","string"]},"581606":{"type":["null","string"]},"581731":{"type":["null","string"]},"582050":{"type":["null","string"]},"582302":{"type":["null","string"]},"582311":{"type":["null","string"]},"582388":{"type":["null","string"]},"582391":{"type":["null","string"]},"582517":{"type":["null","string"]},"582584":{"type":["null","string"]},"582636":{"type":["null","string"]},"582730":{"type":["null","string"]},"Source":{"type":["null","string"]},"_email":{"type":["null","string"]},"_model":{"type":["null","string"]},"amount":{"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"]},"rating":{"type":["null","string"]},"region":{"type":["null","string"]},"roleId":{"type":["null","string"]},"screen":{"type":["null","string"]},"status":{"type":["null","string"]},"af_c_id":{"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"]},"network":{"type":["null","string"]},"payRate":{"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"]},"af_adset":{"type":["null","string"]},"bar_back":{"type":["null","string"]},"bookable":{"type":["null","string"]},"campaign":{"type":["null","string"]},"creation":{"type":["null","string"]},"decision":{"type":["null","string"]},"duration":{"type":["null","string"]},"end_time":{"type":["null","string"]},"features":{"type":["null","string"]},"fin_fp_a":{"type":["null","string"]},"lastName":{"type":["null","string"]},"referrer":{"type":["null","string"]},"skill_id":{"type":["null","string"]},"template":{"type":["null","string"]},"utm_term":{"type":["null","string"]},"workerId":{"type":["null","string"]},"Case Type":{"type":["null","string"]},"add_dates":{"type":["null","string"]},"add_roles":{"type":["null","string"]},"af_siteid":{"type":["null","string"]},"banner_id":{"type":["null","string"]},"bar_staff":{"type":["null","string"]},"c_m_pi_pr":{"type":["null","string"]},"card_type":{"type":["null","string"]},"client_id":{"type":["null","string"]},"device_id":{"type":["null","string"]},"edit_rate":{"type":["null","string"]},"essential":{"type":["null","string"]},"firstName":{"type":["null","string"]},"head_chef":{"type":["null","string"]},"insert_id":{"type":["null","string"]},"lead_chef":{"type":["null","string"]},"p_sc_p_sc":{"type":["null","string"]},"page_name":{"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"]},"af_ad_type":{"type":["null","string"]},"af_channel":{"type":["null","string"]},"build_time":{"type":["null","string"]},"cancel_job":{"type":["null","string"]},"create_job":{"type":["null","string"]},"duration_s":{"type":["null","string"]},"error_type":{"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"]},"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"]},"stocktaker":{"type":["null","string"]},"sunday_day":{"type":["null","string"]},"supervisor":{"type":["null","string"]},"tab_select":{"type":["null","string"]},"time_stamp":{"type":["null","string"]},"utm_medium":{"type":["null","string"]},"utm_source":{"type":["null","string"]},"venue_area":{"type":["null","string"]},"Destination":{"type":["null","string"]},"af_adset_id":{"type":["null","string"]},"af_iad_data":{"type":["null","string"]},"af_keywords":{"type":["null","string"]},"board_board":{"type":["null","string"]},"browse_page":{"type":["null","string"]},"c_m_insight":{"type":["null","string"]},"c_m_pi_r_md":{"type":["null","string"]},"c_m_trading":{"type":["null","string"]},"care_worker":{"type":["null","string"]},"client_name":{"type":["null","string"]},"commis_chef":{"type":["null","string"]},"credit_card":{"type":["null","string"]},"current_url":{"type":["null","string"]},"default_tab":{"type":["null","string"]},"distinct_id":{"type":["null","string"]},"employer_id":{"type":["null","string"]},"event_count":{"type":["null","string"]},"experiments":{"type":["null","string"]},"finance_tax":{"type":["null","string"]},"go_it_pi_is":{"type":["null","string"]},"hr_pensions":{"type":["null","string"]},"industry_id":{"type":["null","string"]},"inviteToken":{"type":["null","string"]},"lib_version":{"type":["null","string"]},"platform_id":{"type":["null","string"]},"reason_text":{"type":["null","string"]},"supervisor_":{"type":["null","string"]},"team_leader":{"type":["null","string"]},"tuesday_day":{"type":["null","string"]},"utm_content":{"type":["null","string"]},"worker_type":{"type":["null","string"]},"Variant name":{"type":["null","string"]},"_destination":{"type":["null","string"]},"availability":{"type":["null","string"]},"backend_host":{"type":["null","string"]},"contractType":{"type":["null","string"]},"errorMessage":{"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"]},"go_it_it_cio":{"type":["null","string"]},"housekeeping":{"type":["null","string"]},"manufacturer":{"type":["null","string"]},"media_source":{"type":["null","string"]},"merchandiser":{"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"]},"uniqueNumber":{"type":["null","string"]},"unread_count":{"type":["null","string"]},"utm_campaign":{"type":["null","string"]},"workerVenues":{"type":["null","string"]},"Case Category":{"type":["null","string"]},"administrator":{"type":["null","string"]},"document_name":{"type":["null","string"]},"employer_gdpr":{"type":["null","string"]},"general_staff":{"type":["null","string"]},"go_it_digital":{"type":["null","string"]},"has_telephone":{"type":["null","string"]},"hr_resourcing":{"type":["null","string"]},"industry_name":{"type":["null","string"]},"overseas_work":{"type":["null","string"]},"picker_packer":{"type":["null","string"]},"place_in_list":{"type":["null","string"]},"refuse_loader":{"type":["null","string"]},"screen_height":{"type":["null","string"]},"search_engine":{"type":["null","string"]},"select_shifts":{"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"]},"amount_entered":{"type":["null","string"]},"c_m_e_commerce":{"type":["null","string"]},"care_assistant":{"type":["null","string"]},"check_out_type":{"type":["null","string"]},"chef_de_partie":{"type":["null","string"]},"festival_staff":{"type":["null","string"]},"form_i9_passed":{"type":["null","string"]},"go_it_security":{"type":["null","string"]},"hr_hr_director":{"type":["null","string"]},"kitchen_porter":{"type":["null","string"]},"legal_document":{"type":["null","string"]},"premier_inn_md":{"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"]},"build_timestamp":{"type":["null","string"]},"delivery_driver":{"type":["null","string"]},"door_supervisor":{"type":["null","string"]},"employer_banned":{"type":["null","string"]},"events_security":{"type":["null","string"]},"general_counsel":{"type":["null","string"]},"hiring_capacity":{"type":["null","string"]},"mp_country_code":{"type":["null","string"]},"sales_assistant":{"type":["null","string"]},"sampling_factor":{"type":["null","integer"]},"telephoneNumber":{"type":["null","string"]},"verified_status":{"type":["null","string"]},"wednesday_early":{"type":["null","string"]},"wednesday_night":{"type":["null","string"]},"worker_verified":{"type":["null","string"]},"amount_requested":{"type":["null","string"]},"app_build_number":{"type":["null","string"]},"c_m_propositions":{"type":["null","string"]},"central_ops_pi_r":{"type":["null","string"]},"company_creation":{"type":["null","string"]},"data_entry_clerk":{"type":["null","string"]},"ed_noms_trainers":{"type":["null","string"]},"event_technician":{"type":["null","string"]},"fin_internal_a_r":{"type":["null","string"]},"finance_treasury":{"type":["null","string"]},"impersonating_id":{"type":["null","string"]},"impression_based":{"type":["null","string"]},"initial_referrer":{"type":["null","string"]},"invitationSentAt":{"type":["null","string"]},"p_i_construction":{"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"]},"c_m_b2b_marketing":{"type":["null","string"]},"call_centre_agent":{"type":["null","string"]},"edit_availability":{"type":["null","string"]},"employer_approved":{"type":["null","string"]},"experiment_home_1":{"type":["null","string"]},"first_verified_at":{"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"]},"assignedRoleSkills":{"type":["null","string"]},"complaints_handler":{"type":["null","string"]},"go_it_architecture":{"type":["null","string"]},"hr_people_director":{"type":["null","string"]},"medical_conditions":{"type":["null","string"]},"motorcycle_courier":{"type":["null","string"]},"start_date_entered":{"type":["null","string"]},"worker_interviewed":{"type":["null","string"]},"c_m_f_b_development":{"type":["null","string"]},"cleaning_supervisor":{"type":["null","string"]},"contact_centre_team":{"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"]},"go_it_tech_services":{"type":["null","string"]},"head_of_programmes_":{"type":["null","string"]},"recycling_operative":{"type":["null","string"]},"role_filter_applied":{"type":["null","string"]},"s_s_safety_security":{"type":["null","string"]},"stockroom_assistant":{"type":["null","string"]},"waiting_staff___vip":{"type":["null","string"]},"warehouse_operative":{"type":["null","string"]},"PlayServices.Version":{"type":["null","string"]},"c_m_decision_science":{"type":["null","string"]},"customer_service_rep":{"type":["null","string"]},"filter_location_unit":{"type":["null","string"]},"google_play_services":{"type":["null","string"]},"hr_hr_internal_comms":{"type":["null","string"]},"hr_talent_capability":{"type":["null","string"]},"p_i_estates_director":{"type":["null","string"]},"bookable_individually":{"type":["null","string"]},"commercial_marketing_":{"type":["null","string"]},"ed_estate_development":{"type":["null","string"]},"hr_employee_relations":{"type":["null","string"]},"hr_hr_shared_services":{"type":["null","string"]},"jobs_and_roles_passed":{"type":["null","string"]},"mp_processing_time_ms":{"type":["null","string"]},"notification_category":{"type":["null","string"]},"numSelectedHardSkills":{"type":["null","string"]},"p_i_property_director":{"type":["null","string"]},"senior_care_assistant":{"type":["null","string"]},"ae_first_app_open_date":{"type":["null","string"]},"c_m_pi_brand_marketing":{"type":["null","string"]},"c_m_sales_distribution":{"type":["null","string"]},"employer_account_level":{"type":["null","string"]},"filter_location_radius":{"type":["null","string"]},"hr_diversity_inclusion":{"type":["null","string"]},"jobs_viewed_in_session":{"type":["null","string"]},"number_of_offered_jobs":{"type":["null","string"]},"online_order_assistant":{"type":["null","string"]},"allow_individual_shifts":{"type":["null","string"]},"c_m_beefeater_marketing":{"type":["null","string"]},"call_centre_team_leader":{"type":["null","string"]},"employer_filter_applied":{"type":["null","string"]},"location_filter_applied":{"type":["null","string"]},"native_navigation_route":{"type":["null","string"]},"p_i_repairs_maintenance":{"type":["null","string"]},"replenishment_assistant":{"type":["null","string"]},"written_reason_provided":{"type":["null","string"]},"c_m_commercial_marketing":{"type":["null","string"]},"c_m_marketing_operations":{"type":["null","string"]},"exec_executive_directors":{"type":["null","string"]},"filter_location_latitude":{"type":["null","string"]},"finance_finance_director":{"type":["null","string"]},"go_non_it_trans_director":{"type":["null","string"]},"hr_reward_insight_policy":{"type":["null","string"]},"initial_referring_domain":{"type":["null","string"]},"number_of_verified_roles":{"type":["null","string"]},"p_i_development_director":{"type":["null","string"]},"rest_rom_res_super_dummy":{"type":["null","string"]},"c_m_restaurants_marketing":{"type":["null","string"]},"contact_centre_management":{"type":["null","string"]},"employer_account_creation":{"type":["null","string"]},"filter_location_longitude":{"type":["null","string"]},"fin_finance_director_pi_r":{"type":["null","string"]},"fin_shared_service_centre":{"type":["null","string"]},"finance_location_strategy":{"type":["null","string"]},"finance_reporting_control":{"type":["null","string"]},"food_production_operative":{"type":["null","string"]},"had_persisted_distinct_id":{"type":["null","string"]},"self_service_verification":{"type":["null","string"]},"venue_access_instructions":{"type":["null","string"]},"fin_ir_corp_comms_strategy":{"type":["null","string"]},"heavy_goods_vehicle_driver":{"type":["null","string"]},"preselected_reason_provided":{"type":["null","string"]},"street_cleansing_operative_":{"type":["null","string"]},"delivery_driver_client_cover":{"type":["null","string"]},"same shift times for all days":{"type":["null","string"]},"videos_and_assessments_passed":{"type":["null","string"]},"p_i_germany_market_development":{"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_UK,additionalProperties={}],syncMode=incremental,cursorField=[time],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@278ea4a4[stream=io.airbyte.protocol.models.AirbyteStream@61c8ab9c[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_UK,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[funnel_id], [date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@752051b7[stream=io.airbyte.protocol.models.AirbyteStream@7139ce84[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_UK,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[date]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@23c0ff83[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@7f0342c[additionalProperties={attemptNumber=0, jobId=2625}],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=1657919227837]]]
2022-07-15 21:07:15 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-15 21:07:09 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/1/logs.log
2022-07-15 21:07:09 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:07:09 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:07:10 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:07:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:07:14 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:07:14 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/1 --log-driver none --name source-mixpanel-check-2625-1-gfjsx --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=2625 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-15 21:07:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-15 21:07:39 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:07:39 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/1/logs.log
2022-07-15 21:07:39 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:07:40 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:07:40 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:07:40 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:07:40 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:07:40 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/1 --log-driver none --name destination-snowflake-check-2625-1-hwbst --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=2625 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-15 21:07:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:07:55 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:07:55 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:07:55 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:07:55 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:07:56 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:08:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:06 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-15 21:08:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:06 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:08:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:06 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-15 21:08:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:06 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:08:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:07 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:08:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:07 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:08:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:07 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:08:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:07 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:08:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:07 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-15 21:08:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:11 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:08:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:22 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3b705be7
2022-07-15 21:08:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:22 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:08:23 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:23 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:08:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:24 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-15 21:08:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:08:24 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-15 21:08:26 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:08:28 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/1/logs.log
2022-07-15 21:08:28 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:08:28 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 2625 attempt id: 1
2022-07-15 21:08:28 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:08:28 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-15 21:08:28 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:08:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-15 21:08:29 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-15 21:08:29 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:08:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/1 --log-driver none --name destination-snowflake-write-2625-1-fgqxh --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=2625 --memory-reservation=28g --memory=28g airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-15 21:08:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:08:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-15 21:08:30 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:08:30 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:08:30 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/1 --log-driver none --name source-mixpanel-read-2625-1-dfflo --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=2625 --memory-reservation=28g --memory=28g airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json
2022-07-15 21:08:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-15 21:08:30 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-15 21:08:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-15 21:08:37 source > Starting syncing SourceMixpanel
2022-07-15 21:08:37 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-15 21:08:37 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:08:37 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:08:37 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-15 21:08:37 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-15 21:08:37 source > Using start_date: 2022-07-01, end_date: 2022-07-15
2022-07-15 21:08:37 source > Syncing stream: export 
2022-07-15 21:08:38 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-15 21:08:46 destination > 2022-07-15 21:08:46 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-15 21:08:46 destination > 2022-07-15 21:08:46 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:08:46 destination > 2022-07-15 21:08:46 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:08:46 destination > 2022-07-15 21:08:46 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:08:49 destination > 2022-07-15 21:08:49 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:08:49 destination > 2022-07-15 21:08:49 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:08:49 destination > 2022-07-15 21:08:49 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:08:49 destination > 2022-07-15 21:08:49 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:08:49 destination > 2022-07-15 21:08:49 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-15 21:08:54 destination > 2022-07-15 21:08:54 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_xzj_export, outputTableName=_airbyte_raw_export, syncMode=append}
2022-07-15 21:08:54 destination > 2022-07-15 21:08:54 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_aof_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append}
2022-07-15 21:08:54 destination > 2022-07-15 21:08:54 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_bwu_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append}
2022-07-15 21:08:55 destination > 2022-07-15 21:08:55 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-15 21:08:55 destination > 2022-07-15 21:08:55 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 3 streams
2022-07-15 21:08:55 destination > 2022-07-15 21:08:55 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream export: tmp table: _airbyte_tmp_xzj_export, stage: 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/
2022-07-15 21:08:56 destination > 2022-07-15 21:08:56 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-15 21:09:08 destination > 2022-07-15 21:09:08 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@29ebbdf4
2022-07-15 21:09:08 destination > 2022-07-15 21:09:08 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-15 21:09:08 destination > 2022-07-15 21:09:08 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:09:09 destination > 2022-07-15 21:09:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream export
2022-07-15 21:09:09 destination > 2022-07-15 21:09:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream funnels: tmp table: _airbyte_tmp_aof_funnels, stage: 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/
2022-07-15 21:09:10 destination > 2022-07-15 21:09:10 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:09:12 destination > 2022-07-15 21:09:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream funnels
2022-07-15 21:09:12 destination > 2022-07-15 21:09:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream revenue: tmp table: _airbyte_tmp_bwu_revenue, stage: 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/
2022-07-15 21:09:12 destination > 2022-07-15 21:09:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-15 21:09:13 destination > 2022-07-15 21:09:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream revenue
2022-07-15 21:09:13 destination > 2022-07-15 21:09:13 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:15 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=55s418ms393µs535ns).
2022-07-15 21:20:31 destination > 2022-07-15 21:20:31 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=6m49s157ms177µs430ns).
2022-07-15 21:20:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):335 - Total records read: 0 (0 bytes)
2022-07-15 21:20:34 destination > 2022-07-15 21:20:34 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-07-15 21:20:34 destination > 2022-07-15 21:20:34 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-07-15 21:20:34 destination > 2022-07-15 21:20:34 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):103 - Flushing all 0 current buffers (0 bytes in total)
2022-07-15 21:20:34 destination > 2022-07-15 21:20:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 3 streams
2022-07-15 21:20:34 destination > 2022-07-15 21:20:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream export of schema MIXPANEL_UK into tmp table _airbyte_tmp_xzj_export to final table _airbyte_raw_export from stage path 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/ with 0 file(s) []
2022-07-15 21:20:35 destination > 2022-07-15 21:20:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream funnels of schema MIXPANEL_UK into tmp table _airbyte_tmp_aof_funnels to final table _airbyte_raw_funnels from stage path 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/ with 0 file(s) []
2022-07-15 21:20:35 destination > 2022-07-15 21:20:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream revenue of schema MIXPANEL_UK into tmp table _airbyte_tmp_bwu_revenue to final table _airbyte_raw_revenue from stage path 2022/07/15/21/59E4E5C2-D5E2-42D0-9B98-A1FEF4089E8D/ with 0 file(s) []
2022-07-15 21:20:36 destination > 2022-07-15 21:20:36 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination.
2022-07-15 21:20:36 destination > 2022-07-15 21:20:36 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):216 - Executing finalization of tables.
2022-07-15 21:20:37 destination > 2022-07-15 21:20:37 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):218 - Finalizing tables in destination completed.
2022-07-15 21:20:37 destination > 2022-07-15 21:20:37 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):220 - Cleaning up destination started for 3 streams
2022-07-15 21:20:37 destination > 2022-07-15 21:20:37 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream export. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_xzj_export
2022-07-15 21:20:38 destination > 2022-07-15 21:20:38 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream export. schema MIXPANEL_UK, stage: MIXPANEL_UK_EXPORT
2022-07-15 21:20:38 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation...
2022-07-15 21:20:38 INFO i.a.w.g.DefaultReplicationWorker(cancel):443 - Cancelling replication worker...
2022-07-15 21:20:38 destination > 2022-07-15 21:20:38 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream funnels. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_aof_funnels
2022-07-15 21:20:38 destination > 2022-07-15 21:20:38 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream funnels. schema MIXPANEL_UK, stage: MIXPANEL_UK_FUNNELS
2022-07-15 21:20:39 destination > 2022-07-15 21:20:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):224 - Cleaning tmp table in destination started for stream revenue. schema MIXPANEL_UK, tmp table name: _airbyte_tmp_bwu_revenue
2022-07-15 21:20:39 destination > 2022-07-15 21:20:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning stage in destination started for stream revenue. schema MIXPANEL_UK, stage: MIXPANEL_UK_REVENUE
2022-07-15 21:20:39 destination > 2022-07-15 21:20:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):235 - Cleaning up destination completed.
2022-07-15 21:20:39 destination > 2022-07-15 21:20:39 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:20:41 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 137
	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 process exited with non-zero exit code 137
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:348) ~[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:20:41 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@5f592757[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657919308641,endTime=1657920041916,totalStats=io.airbyte.config.SyncStats@67a4ebc0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-07-15 21:20:41 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-15 21:20:41 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-07-15 21:20:41 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-15 21:20:41 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@5488f32[standardSyncSummary=io.airbyte.config.StandardSyncSummary@404a01ff[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657919308641,endTime=1657920041916,totalStats=io.airbyte.config.SyncStats@67a4ebc0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@48d06f40[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@714064b5[stream=io.airbyte.protocol.models.AirbyteStream@303054b0[name=export,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"c":{"type":["null","string"]},"id":{"type":["null","string"]},"os":{"type":["null","string"]},"to":{"type":["null","string"]},"URL":{"type":["null","string"]},"app":{"type":["null","string"]},"area":{"type":["null","string"]},"args":{"type":["null","string"]},"city":{"type":["null","string"]},"code":{"type":["null","string"]},"date":{"type":["null","string"]},"from":{"type":["null","string"]},"page":{"type":["null","string"]},"rate":{"type":["null","string"]},"size":{"type":["null","string"]},"time":{"type":["null","string"],"format":"date-time"},"type":{"type":["null","string"]},"wifi":{"type":["null","string"]},"_wifi":{"type":["null","string"]},"admin":{"type":["null","string"]},"brand":{"type":["null","string"]},"break":{"type":["null","string"]},"dates":{"type":["null","string"]},"email":{"type":["null","string"]},"error":{"type":["null","string"]},"event":{"type":["null","string"]},"model":{"type":["null","string"]},"nudge":{"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"]},"539354":{"type":["null","string"]},"541357":{"type":["null","string"]},"541399":{"type":["null","string"]},"546665":{"type":["null","string"]},"547254":{"type":["null","string"]},"548512":{"type":["null","string"]},"548513":{"type":["null","string"]},"549154":{"type":["null","string"]},"549155":{"type":["null","string"]},"549268":{"type":["null","string"]},"549677":{"type":["null","string"]},"549679":{"type":["null","string"]},"550377":{"type":["null","string"]},"550378":{"type":["null","string"]},"550380":{"type":["null","string"]},"550931":{"type":["null","string"]},"551061":{"type":["null","string"]},"551073":{"type":["null","string"]},"552730":{"type":["null","string"]},"552956":{"type":["null","string"]},"553005":{"type":["null","string"]},"553768":{"type":["null","string"]},"553777":{"type":["null","string"]},"554031":{"type":["null","string"]},"554045":{"type":["null","string"]},"554047":{"type":["null","string"]},"554320":{"type":["null","string"]},"554831":{"type":["null","string"]},"554947":{"type":["null","string"]},"554956":{"type":["null","string"]},"554961":{"type":["null","string"]},"554963":{"type":["null","string"]},"554975":{"type":["null","string"]},"555345":{"type":["null","string"]},"555654":{"type":["null","string"]},"555670":{"type":["null","string"]},"555672":{"type":["null","string"]},"555675":{"type":["null","string"]},"555709":{"type":["null","string"]},"555905":{"type":["null","string"]},"556001":{"type":["null","string"]},"556015":{"type":["null","string"]},"557231":{"type":["null","string"]},"557314":{"type":["null","string"]},"557544":{"type":["null","string"]},"557787":{"type":["null","string"]},"557848":{"type":["null","string"]},"558074":{"type":["null","string"]},"558351":{"type":["null","string"]},"558364":{"type":["null","string"]},"558614":{"type":["null","string"]},"558616":{"type":["null","string"]},"558754":{"type":["null","string"]},"558756":{"type":["null","string"]},"558973":{"type":["null","string"]},"559056":{"type":["null","string"]},"559057":{"type":["null","string"]},"559238":{"type":["null","string"]},"559263":{"type":["null","string"]},"559346":{"type":["null","string"]},"559724":{"type":["null","string"]},"559725":{"type":["null","string"]},"559726":{"type":["null","string"]},"559908":{"type":["null","string"]},"559932":{"type":["null","string"]},"559967":{"type":["null","string"]},"559973":{"type":["null","string"]},"560130":{"type":["null","string"]},"560136":{"type":["null","string"]},"560142":{"type":["null","string"]},"560172":{"type":["null","string"]},"560200":{"type":["null","string"]},"560222":{"type":["null","string"]},"560223":{"type":["null","string"]},"560241":{"type":["null","string"]},"560354":{"type":["null","string"]},"560367":{"type":["null","string"]},"560835":{"type":["null","string"]},"560837":{"type":["null","string"]},"561330":{"type":["null","string"]},"561379":{"type":["null","string"]},"561722":{"type":["null","string"]},"561826":{"type":["null","string"]},"561830":{"type":["null","string"]},"561834":{"type":["null","string"]},"561841":{"type":["null","string"]},"561843":{"type":["null","string"]},"561906":{"type":["null","string"]},"561949":{"type":["null","string"]},"562030":{"type":["null","string"]},"562069":{"type":["null","string"]},"562129":{"type":["null","string"]},"562132":{"type":["null","string"]},"562199":{"type":["null","string"]},"562206":{"type":["null","string"]},"562244":{"type":["null","string"]},"562445":{"type":["null","string"]},"562449":{"type":["null","string"]},"562510":{"type":["null","string"]},"562708":{"type":["null","string"]},"562800":{"type":["null","string"]},"562802":{"type":["null","string"]},"562920":{"type":["null","string"]},"562942":{"type":["null","string"]},"562994":{"type":["null","string"]},"563014":{"type":["null","string"]},"563043":{"type":["null","string"]},"563226":{"type":["null","string"]},"563228":{"type":["null","string"]},"563329":{"type":["null","string"]},"563330":{"type":["null","string"]},"563435":{"type":["null","string"]},"564055":{"type":["null","string"]},"564080":{"type":["null","string"]},"564215":{"type":["null","string"]},"564286":{"type":["null","string"]},"564390":{"type":["null","string"]},"564413":{"type":["null","string"]},"564494":{"type":["null","string"]},"564630":{"type":["null","string"]},"564639":{"type":["null","string"]},"564645":{"type":["null","string"]},"564682":{"type":["null","string"]},"564704":{"type":["null","string"]},"564721":{"type":["null","string"]},"564732":{"type":["null","string"]},"564741":{"type":["null","string"]},"565318":{"type":["null","string"]},"565319":{"type":["null","string"]},"565461":{"type":["null","string"]},"565470":{"type":["null","string"]},"565634":{"type":["null","string"]},"565672":{"type":["null","string"]},"566029":{"type":["null","string"]},"566146":{"type":["null","string"]},"566227":{"type":["null","string"]},"566318":{"type":["null","string"]},"566409":{"type":["null","string"]},"566441":{"type":["null","string"]},"566448":{"type":["null","string"]},"566450":{"type":["null","string"]},"566451":{"type":["null","string"]},"566626":{"type":["null","string"]},"566655":{"type":["null","string"]},"566715":{"type":["null","string"]},"566718":{"type":["null","string"]},"566829":{"type":["null","string"]},"566972":{"type":["null","string"]},"566994":{"type":["null","string"]},"567032":{"type":["null","string"]},"567049":{"type":["null","string"]},"567699":{"type":["null","string"]},"567784":{"type":["null","string"]},"567996":{"type":["null","string"]},"568040":{"type":["null","string"]},"568061":{"type":["null","string"]},"568062":{"type":["null","string"]},"568085":{"type":["null","string"]},"568469":{"type":["null","string"]},"568499":{"type":["null","string"]},"568501":{"type":["null","string"]},"568751":{"type":["null","string"]},"568754":{"type":["null","string"]},"568769":{"type":["null","string"]},"568926":{"type":["null","string"]},"569085":{"type":["null","string"]},"569221":{"type":["null","string"]},"569571":{"type":["null","string"]},"569584":{"type":["null","string"]},"569661":{"type":["null","string"]},"569671":{"type":["null","string"]},"569672":{"type":["null","string"]},"569692":{"type":["null","string"]},"569693":{"type":["null","string"]},"569694":{"type":["null","string"]},"569700":{"type":["null","string"]},"569701":{"type":["null","string"]},"569727":{"type":["null","string"]},"569736":{"type":["null","string"]},"569795":{"type":["null","string"]},"569982":{"type":["null","string"]},"570036":{"type":["null","string"]},"570042":{"type":["null","string"]},"570043":{"type":["null","string"]},"570264":{"type":["null","string"]},"570308":{"type":["null","string"]},"570427":{"type":["null","string"]},"570428":{"type":["null","string"]},"570483":{"type":["null","string"]},"570521":{"type":["null","string"]},"570528":{"type":["null","string"]},"570698":{"type":["null","string"]},"570836":{"type":["null","string"]},"570886":{"type":["null","string"]},"570924":{"type":["null","string"]},"571086":{"type":["null","string"]},"571369":{"type":["null","string"]},"571443":{"type":["null","string"]},"571592":{"type":["null","string"]},"571676":{"type":["null","string"]},"571721":{"type":["null","string"]},"571775":{"type":["null","string"]},"571992":{"type":["null","string"]},"572221":{"type":["null","string"]},"572222":{"type":["null","string"]},"572318":{"type":["null","string"]},"572321":{"type":["null","string"]},"572346":{"type":["null","string"]},"572483":{"type":["null","string"]},"572714":{"type":["null","string"]},"572754":{"type":["null","string"]},"572762":{"type":["null","string"]},"572763":{"type":["null","string"]},"572772":{"type":["null","string"]},"572778":{"type":["null","string"]},"572804":{"type":["null","string"]},"572938":{"type":["null","string"]},"573083":{"type":["null","string"]},"573150":{"type":["null","string"]},"573460":{"type":["null","string"]},"573486":{"type":["null","string"]},"573503":{"type":["null","string"]},"573530":{"type":["null","string"]},"573654":{"type":["null","string"]},"573684":{"type":["null","string"]},"573835":{"type":["null","string"]},"574303":{"type":["null","string"]},"574344":{"type":["null","string"]},"574395":{"type":["null","string"]},"574499":{"type":["null","string"]},"574559":{"type":["null","string"]},"574595":{"type":["null","string"]},"574652":{"type":["null","string"]},"574671":{"type":["null","string"]},"574673":{"type":["null","string"]},"574886":{"type":["null","string"]},"574949":{"type":["null","string"]},"575101":{"type":["null","string"]},"575188":{"type":["null","string"]},"575287":{"type":["null","string"]},"575541":{"type":["null","string"]},"575643":{"type":["null","string"]},"576086":{"type":["null","string"]},"576116":{"type":["null","string"]},"576214":{"type":["null","string"]},"576291":{"type":["null","string"]},"576335":{"type":["null","string"]},"576364":{"type":["null","string"]},"576459":{"type":["null","string"]},"576508":{"type":["null","string"]},"576687":{"type":["null","string"]},"576853":{"type":["null","string"]},"576854":{"type":["null","string"]},"576857":{"type":["null","string"]},"576913":{"type":["null","string"]},"576964":{"type":["null","string"]},"577397":{"type":["null","string"]},"578232":{"type":["null","string"]},"579309":{"type":["null","string"]},"579310":{"type":["null","string"]},"579325":{"type":["null","string"]},"579496":{"type":["null","string"]},"579748":{"type":["null","string"]},"580150":{"type":["null","string"]},"580151":{"type":["null","string"]},"580414":{"type":["null","string"]},"580422":{"type":["null","string"]},"580526":{"type":["null","string"]},"580530":{"type":["null","string"]},"580534":{"type":["null","string"]},"580573":{"type":["null","string"]},"580582":{"type":["null","string"]},"580584":{"type":["null","string"]},"580588":{"type":["null","string"]},"580589":{"type":["null","string"]},"580590":{"type":["null","string"]},"580948":{"type":["null","string"]},"580968":{"type":["null","string"]},"581027":{"type":["null","string"]},"581270":{"type":["null","string"]},"581273":{"type":["null","string"]},"581279":{"type":["null","string"]},"581284":{"type":["null","string"]},"581477":{"type":["null","string"]},"581606":{"type":["null","string"]},"581731":{"type":["null","string"]},"582050":{"type":["null","string"]},"582302":{"type":["null","string"]},"582311":{"type":["null","string"]},"582388":{"type":["null","string"]},"582391":{"type":["null","string"]},"582517":{"type":["null","string"]},"582584":{"type":["null","string"]},"582636":{"type":["null","string"]},"582730":{"type":["null","string"]},"Source":{"type":["null","string"]},"_email":{"type":["null","string"]},"_model":{"type":["null","string"]},"amount":{"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"]},"rating":{"type":["null","string"]},"region":{"type":["null","string"]},"roleId":{"type":["null","string"]},"screen":{"type":["null","string"]},"status":{"type":["null","string"]},"af_c_id":{"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"]},"network":{"type":["null","string"]},"payRate":{"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"]},"af_adset":{"type":["null","string"]},"bar_back":{"type":["null","string"]},"bookable":{"type":["null","string"]},"campaign":{"type":["null","string"]},"creation":{"type":["null","string"]},"decision":{"type":["null","string"]},"duration":{"type":["null","string"]},"end_time":{"type":["null","string"]},"features":{"type":["null","string"]},"fin_fp_a":{"type":["null","string"]},"lastName":{"type":["null","string"]},"referrer":{"type":["null","string"]},"skill_id":{"type":["null","string"]},"template":{"type":["null","string"]},"utm_term":{"type":["null","string"]},"workerId":{"type":["null","string"]},"Case Type":{"type":["null","string"]},"add_dates":{"type":["null","string"]},"add_roles":{"type":["null","string"]},"af_siteid":{"type":["null","string"]},"banner_id":{"type":["null","string"]},"bar_staff":{"type":["null","string"]},"c_m_pi_pr":{"type":["null","string"]},"card_type":{"type":["null","string"]},"client_id":{"type":["null","string"]},"device_id":{"type":["null","string"]},"edit_rate":{"type":["null","string"]},"essential":{"type":["null","string"]},"firstName":{"type":["null","string"]},"head_chef":{"type":["null","string"]},"insert_id":{"type":["null","string"]},"lead_chef":{"type":["null","string"]},"p_sc_p_sc":{"type":["null","string"]},"page_name":{"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"]},"af_ad_type":{"type":["null","string"]},"af_channel":{"type":["null","string"]},"build_time":{"type":["null","string"]},"cancel_job":{"type":["null","string"]},"create_job":{"type":["null","string"]},"duration_s":{"type":["null","string"]},"error_type":{"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"]},"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"]},"stocktaker":{"type":["null","string"]},"sunday_day":{"type":["null","string"]},"supervisor":{"type":["null","string"]},"tab_select":{"type":["null","string"]},"time_stamp":{"type":["null","string"]},"utm_medium":{"type":["null","string"]},"utm_source":{"type":["null","string"]},"venue_area":{"type":["null","string"]},"Destination":{"type":["null","string"]},"af_adset_id":{"type":["null","string"]},"af_iad_data":{"type":["null","string"]},"af_keywords":{"type":["null","string"]},"board_board":{"type":["null","string"]},"browse_page":{"type":["null","string"]},"c_m_insight":{"type":["null","string"]},"c_m_pi_r_md":{"type":["null","string"]},"c_m_trading":{"type":["null","string"]},"care_worker":{"type":["null","string"]},"client_name":{"type":["null","string"]},"commis_chef":{"type":["null","string"]},"credit_card":{"type":["null","string"]},"current_url":{"type":["null","string"]},"default_tab":{"type":["null","string"]},"distinct_id":{"type":["null","string"]},"employer_id":{"type":["null","string"]},"event_count":{"type":["null","string"]},"experiments":{"type":["null","string"]},"finance_tax":{"type":["null","string"]},"go_it_pi_is":{"type":["null","string"]},"hr_pensions":{"type":["null","string"]},"industry_id":{"type":["null","string"]},"inviteToken":{"type":["null","string"]},"lib_version":{"type":["null","string"]},"platform_id":{"type":["null","string"]},"reason_text":{"type":["null","string"]},"supervisor_":{"type":["null","string"]},"team_leader":{"type":["null","string"]},"tuesday_day":{"type":["null","string"]},"utm_content":{"type":["null","string"]},"worker_type":{"type":["null","string"]},"Variant name":{"type":["null","string"]},"_destination":{"type":["null","string"]},"availability":{"type":["null","string"]},"backend_host":{"type":["null","string"]},"contractType":{"type":["null","string"]},"errorMessage":{"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"]},"go_it_it_cio":{"type":["null","string"]},"housekeeping":{"type":["null","string"]},"manufacturer":{"type":["null","string"]},"media_source":{"type":["null","string"]},"merchandiser":{"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"]},"uniqueNumber":{"type":["null","string"]},"unread_count":{"type":["null","string"]},"utm_campaign":{"type":["null","string"]},"workerVenues":{"type":["null","string"]},"Case Category":{"type":["null","string"]},"administrator":{"type":["null","string"]},"document_name":{"type":["null","string"]},"employer_gdpr":{"type":["null","string"]},"general_staff":{"type":["null","string"]},"go_it_digital":{"type":["null","string"]},"has_telephone":{"type":["null","string"]},"hr_resourcing":{"type":["null","string"]},"industry_name":{"type":["null","string"]},"overseas_work":{"type":["null","string"]},"picker_packer":{"type":["null","string"]},"place_in_list":{"type":["null","string"]},"refuse_loader":{"type":["null","string"]},"screen_height":{"type":["null","string"]},"search_engine":{"type":["null","string"]},"select_shifts":{"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"]},"amount_entered":{"type":["null","string"]},"c_m_e_commerce":{"type":["null","string"]},"care_assistant":{"type":["null","string"]},"check_out_type":{"type":["null","string"]},"chef_de_partie":{"type":["null","string"]},"festival_staff":{"type":["null","string"]},"form_i9_passed":{"type":["null","string"]},"go_it_security":{"type":["null","string"]},"hr_hr_director":{"type":["null","string"]},"kitchen_porter":{"type":["null","string"]},"legal_document":{"type":["null","string"]},"premier_inn_md":{"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"]},"build_timestamp":{"type":["null","string"]},"delivery_driver":{"type":["null","string"]},"door_supervisor":{"type":["null","string"]},"employer_banned":{"type":["null","string"]},"events_security":{"type":["null","string"]},"general_counsel":{"type":["null","string"]},"hiring_capacity":{"type":["null","string"]},"mp_country_code":{"type":["null","string"]},"sales_assistant":{"type":["null","string"]},"sampling_factor":{"type":["null","integer"]},"telephoneNumber":{"type":["null","string"]},"verified_status":{"type":["null","string"]},"wednesday_early":{"type":["null","string"]},"wednesday_night":{"type":["null","string"]},"worker_verified":{"type":["null","string"]},"amount_requested":{"type":["null","string"]},"app_build_number":{"type":["null","string"]},"c_m_propositions":{"type":["null","string"]},"central_ops_pi_r":{"type":["null","string"]},"company_creation":{"type":["null","string"]},"data_entry_clerk":{"type":["null","string"]},"ed_noms_trainers":{"type":["null","string"]},"event_technician":{"type":["null","string"]},"fin_internal_a_r":{"type":["null","string"]},"finance_treasury":{"type":["null","string"]},"impersonating_id":{"type":["null","string"]},"impression_based":{"type":["null","string"]},"initial_referrer":{"type":["null","string"]},"invitationSentAt":{"type":["null","string"]},"p_i_construction":{"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"]},"c_m_b2b_marketing":{"type":["null","string"]},"call_centre_agent":{"type":["null","string"]},"edit_availability":{"type":["null","string"]},"employer_approved":{"type":["null","string"]},"experiment_home_1":{"type":["null","string"]},"first_verified_at":{"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"]},"assignedRoleSkills":{"type":["null","string"]},"complaints_handler":{"type":["null","string"]},"go_it_architecture":{"type":["null","string"]},"hr_people_director":{"type":["null","string"]},"medical_conditions":{"type":["null","string"]},"motorcycle_courier":{"type":["null","string"]},"start_date_entered":{"type":["null","string"]},"worker_interviewed":{"type":["null","string"]},"c_m_f_b_development":{"type":["null","string"]},"cleaning_supervisor":{"type":["null","string"]},"contact_centre_team":{"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"]},"go_it_tech_services":{"type":["null","string"]},"head_of_programmes_":{"type":["null","string"]},"recycling_operative":{"type":["null","string"]},"role_filter_applied":{"type":["null","string"]},"s_s_safety_security":{"type":["null","string"]},"stockroom_assistant":{"type":["null","string"]},"waiting_staff___vip":{"type":["null","string"]},"warehouse_operative":{"type":["null","string"]},"PlayServices.Version":{"type":["null","string"]},"c_m_decision_science":{"type":["null","string"]},"customer_service_rep":{"type":["null","string"]},"filter_location_unit":{"type":["null","string"]},"google_play_services":{"type":["null","string"]},"hr_hr_internal_comms":{"type":["null","string"]},"hr_talent_capability":{"type":["null","string"]},"p_i_estates_director":{"type":["null","string"]},"bookable_individually":{"type":["null","string"]},"commercial_marketing_":{"type":["null","string"]},"ed_estate_development":{"type":["null","string"]},"hr_employee_relations":{"type":["null","string"]},"hr_hr_shared_services":{"type":["null","string"]},"jobs_and_roles_passed":{"type":["null","string"]},"mp_processing_time_ms":{"type":["null","string"]},"notification_category":{"type":["null","string"]},"numSelectedHardSkills":{"type":["null","string"]},"p_i_property_director":{"type":["null","string"]},"senior_care_assistant":{"type":["null","string"]},"ae_first_app_open_date":{"type":["null","string"]},"c_m_pi_brand_marketing":{"type":["null","string"]},"c_m_sales_distribution":{"type":["null","string"]},"employer_account_level":{"type":["null","string"]},"filter_location_radius":{"type":["null","string"]},"hr_diversity_inclusion":{"type":["null","string"]},"jobs_viewed_in_session":{"type":["null","string"]},"number_of_offered_jobs":{"type":["null","string"]},"online_order_assistant":{"type":["null","string"]},"allow_individual_shifts":{"type":["null","string"]},"c_m_beefeater_marketing":{"type":["null","string"]},"call_centre_team_leader":{"type":["null","string"]},"employer_filter_applied":{"type":["null","string"]},"location_filter_applied":{"type":["null","string"]},"native_navigation_route":{"type":["null","string"]},"p_i_repairs_maintenance":{"type":["null","string"]},"replenishment_assistant":{"type":["null","string"]},"written_reason_provided":{"type":["null","string"]},"c_m_commercial_marketing":{"type":["null","string"]},"c_m_marketing_operations":{"type":["null","string"]},"exec_executive_directors":{"type":["null","string"]},"filter_location_latitude":{"type":["null","string"]},"finance_finance_director":{"type":["null","string"]},"go_non_it_trans_director":{"type":["null","string"]},"hr_reward_insight_policy":{"type":["null","string"]},"initial_referring_domain":{"type":["null","string"]},"number_of_verified_roles":{"type":["null","string"]},"p_i_development_director":{"type":["null","string"]},"rest_rom_res_super_dummy":{"type":["null","string"]},"c_m_restaurants_marketing":{"type":["null","string"]},"contact_centre_management":{"type":["null","string"]},"employer_account_creation":{"type":["null","string"]},"filter_location_longitude":{"type":["null","string"]},"fin_finance_director_pi_r":{"type":["null","string"]},"fin_shared_service_centre":{"type":["null","string"]},"finance_location_strategy":{"type":["null","string"]},"finance_reporting_control":{"type":["null","string"]},"food_production_operative":{"type":["null","string"]},"had_persisted_distinct_id":{"type":["null","string"]},"self_service_verification":{"type":["null","string"]},"venue_access_instructions":{"type":["null","string"]},"fin_ir_corp_comms_strategy":{"type":["null","string"]},"heavy_goods_vehicle_driver":{"type":["null","string"]},"preselected_reason_provided":{"type":["null","string"]},"street_cleansing_operative_":{"type":["null","string"]},"delivery_driver_client_cover":{"type":["null","string"]},"same shift times for all days":{"type":["null","string"]},"videos_and_assessments_passed":{"type":["null","string"]},"p_i_germany_market_development":{"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_UK,additionalProperties={}],syncMode=incremental,cursorField=[time],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2065feb0[stream=io.airbyte.protocol.models.AirbyteStream@6b042f93[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_UK,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[funnel_id], [date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@19938b8a[stream=io.airbyte.protocol.models.AirbyteStream@2b34d9dc[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_UK,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[date]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@242b2274[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 137,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@6e19e9d5[additionalProperties={attemptNumber=1, jobId=2625}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 137
	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 process exited with non-zero exit code 137
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:348)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1657920034060]]]
2022-07-15 21:20:41 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-15 21:20:41 INFO i.a.w.g.DefaultReplicationWorker(cancel):451 - Cancelling destination...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-07-15 21:20:41 INFO i.a.w.g.DefaultReplicationWorker(cancel):458 - Cancelling source...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-07-15 21:20:41 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-07-15 21:20:41 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread...
2022-07-15 21:20:41 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future...
2022-07-15 21:20:41 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-15 21:20:35 INFO i.a.c.f.EnvVariableFeatureFlags(autoDisablesFailingConnections):17 - Auto Disable Failing Connections: false
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:36 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/2/logs.log
2022-07-15 21:20:36 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
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: 2625
2022-07-15 21:20:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/2 --log-driver none --name source-mixpanel-check-2625-2-nuobd --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=2625 --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:53 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/2625/2/logs.log
2022-07-15 21:20:53 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.33-alpha
2022-07-15 21:20:53 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-15 21:20:53 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: 2625
2022-07-15 21:20:53 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/2 --log-driver none --name destination-snowflake-check-2625-2-taheg --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=2625 --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:13 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:13 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 order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-15 21:21:13 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 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:13 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 multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-15 21:21:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:13 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:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 21:21:29 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/2625/2/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: 2625 attempt id: 2
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: 2625
2022-07-15 21:21:32 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/2 --log-driver none --name destination-snowflake-write-2625-2-siqsp --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=2625 --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:32 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-15 21:21:32 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 2625
2022-07-15 21:21:32 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/2625/2 --log-driver none --name source-mixpanel-read-2625-2-zrefd --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=2625 --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.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
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: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:49 destination > 2022-07-15 21:21:49 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:49 destination > 2022-07-15 21:21:49 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-15 21:21:49 destination > 2022-07-15 21:21:49 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-15 21:21:49 destination > 2022-07-15 21:21:49 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:51 destination > 2022-07-15 21:21:51 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:51 destination > 2022-07-15 21:21:51 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:51 destination > 2022-07-15 21:21:51 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:51 destination > 2022-07-15 21:21:51 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:52 destination > 2022-07-15 21:21:52 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:57 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=MIXPANEL_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_rcv_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_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_cso_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_UK, outputSchemaName=MIXPANEL_UK, tmpTableName=_airbyte_tmp_vgn_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_UK stream export: tmp table: _airbyte_tmp_rcv_export, stage: 2022/07/15/21/83CD1E45-1A67-4CB4-AB5E-AFC51E417E23/
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:10 destination > 2022-07-15 21:22:10 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@254449bb
2022-07-15 21:22:10 destination > 2022-07-15 21:22:10 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
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_UK 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_UK stream funnels: tmp table: _airbyte_tmp_cso_funnels, stage: 2022/07/15/21/83CD1E45-1A67-4CB4-AB5E-AFC51E417E23/
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: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_UK stream funnels
2022-07-15 21:22:13 destination > 2022-07-15 21:22:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MIXPANEL_UK stream revenue: tmp table: _airbyte_tmp_vgn_revenue, stage: 2022/07/15/21/83CD1E45-1A67-4CB4-AB5E-AFC51E417E23/
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:14 destination > 2022-07-15 21:22:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MIXPANEL_UK stream revenue
2022-07-15 21:22:14 destination > 2022-07-15 21:22:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-15 21:37:46 destination > 2022-07-15 21:32:57 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=45s188ms756µs462ns).
2022-07-15 21:43:33 destination > 2022-07-15 21:37:10 WARN c.z.h.p.HikariPool$HouseKeeper(run):804 - HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=6m35s398ms69µs486ns).