2022-04-21 17:42:28 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-04-21 17:42:28 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/11/2/logs.log 2022-04-21 17:42:28 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-04-21 17:42:28 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 11 attempt id: 2 2022-04-21 17:42:28 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {Auth._queue=full_refresh - append, Auth.applications=full_refresh - append, Auth.users=full_refresh - append, Auth._systemSubscriptions=full_refresh - append, Auth._healthCheck=full_refresh - append, Auth._requestLogs=full_refresh - append, Auth.auditLogins=full_refresh - append, Auth.securityCodes=full_refresh - append, Auth.tokens=full_refresh - append, Auth._scheduledTasks=full_refresh - append} 2022-04-21 17:42:28 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-21 17:42:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.24 exists... 2022-04-21 17:42:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.24 was found locally. 2022-04-21 17:42:28 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 11 2022-04-21 17:42:28 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/11/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.24 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=11 airbyte/destination-snowflake:0.4.24 write --config destination_config.json --catalog destination_catalog.json 2022-04-21 17:42:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:0.1.13 exists... 2022-04-21 17:42:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:0.1.13 was found locally. 2022-04-21 17:42:28 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 11 2022-04-21 17:42:28 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/11/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.13 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=11 airbyte/source-mongodb-v2:0.1.13 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-04-21 17:42:28 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-21 17:42:28 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-21 17:42:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-21 17:42:28 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-21 17:42:28 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-21 17:42:28 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-21 17:42:28 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-21 17:42:29 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.m.MongoDbSource(main):64 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 1784e018c36c4f6b89ded8961d24e95f 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-04-21 17:42:29 destination > 2022-04-21 17:42:29 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='tokens', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='applications', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_systemSubscriptions', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_queue', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_requestLogs', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='securityCodes', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_healthCheck', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='auditLogins', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='users', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_scheduledTasks', namespace='Auth'}, New Cursor Field: null. Resetting cursor value 2022-04-21 17:42:29 source > 2022-04-21 17:42:29 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[alpha-db-mongo-ro.wonscore.io:27093], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} 2022-04-21 17:42:30 source > 2022-04-21 17:42:29 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=_healthCheck, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_ssw__healthCheck, outputTableName=_airbyte_raw__healthCheck, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=_queue, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_onp__queue, outputTableName=_airbyte_raw__queue, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=_requestLogs, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_iyn__requestLogs, outputTableName=_airbyte_raw__requestLogs, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=_scheduledTasks, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_pef__scheduledTasks, outputTableName=_airbyte_raw__scheduledTasks, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=_systemSubscriptions, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_nyz__systemSubscriptions, outputTableName=_airbyte_raw__systemSubscriptions, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=applications, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_qxj_applications, outputTableName=_airbyte_raw_applications, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=auditLogins, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_czz_auditLogins, outputTableName=_airbyte_raw_auditLogins, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=securityCodes, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_mma_securityCodes, outputTableName=_airbyte_raw_securityCodes, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=tokens, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_ngx_tokens, outputTableName=_airbyte_raw_tokens, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=users, namespace=Auth, outputSchemaName=Auth, tmpTableName=_airbyte_tmp_muu_users, outputTableName=_airbyte_raw_users, syncMode=append} 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 10 streams 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream _healthCheck: tmp table: _airbyte_tmp_ssw__healthCheck, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:30 destination > 2022-04-21 17:42:30 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-04-21 17:42:31 destination > 2022-04-21 17:42:31 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@7c011174 2022-04-21 17:42:31 destination > 2022-04-21 17:42:31 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-04-21 17:42:31 destination > 2022-04-21 17:42:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream _healthCheck 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream _queue: tmp table: _airbyte_tmp_onp__queue, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream _queue 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream _requestLogs: tmp table: _airbyte_tmp_iyn__requestLogs, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:32 destination > 2022-04-21 17:42:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream _requestLogs 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream _scheduledTasks: tmp table: _airbyte_tmp_pef__scheduledTasks, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream _scheduledTasks 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream _systemSubscriptions: tmp table: _airbyte_tmp_nyz__systemSubscriptions, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:33 destination > 2022-04-21 17:42:33 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream _systemSubscriptions 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream applications: tmp table: _airbyte_tmp_qxj_applications, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream applications 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream auditLogins: tmp table: _airbyte_tmp_czz_auditLogins, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream auditLogins 2022-04-21 17:42:34 destination > 2022-04-21 17:42:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream securityCodes: tmp table: _airbyte_tmp_mma_securityCodes, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream securityCodes 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream tokens: tmp table: _airbyte_tmp_ngx_tokens, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream tokens 2022-04-21 17:42:35 destination > 2022-04-21 17:42:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema Auth stream users: tmp table: _airbyte_tmp_muu_users, stage: 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ 2022-04-21 17:42:36 destination > 2022-04-21 17:42:36 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-21 17:42:36 destination > 2022-04-21 17:42:36 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema Auth stream users 2022-04-21 17:42:36 destination > 2022-04-21 17:42:36 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed. 2022-04-21 17:42:40 source > 2022-04-21 17:42:40 INFO c.m.d.l.SLF4JLogger(info):76 - Exception in monitor thread while connecting to server alpha-db-mongo-ro.wonscore.io:27093 2022-04-21 17:42:40 source > com.mongodb.MongoSocketOpenException: Exception opening socket 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.SocketStream.open(SocketStream.java:70) ~[mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:180) ~[mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.lookupServerDescription(DefaultServerMonitor.java:188) [mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:152) [mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-21 17:42:40 source > Caused by: java.net.SocketTimeoutException: Connect timed out 2022-04-21 17:42:40 source > at sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:546) ~[?:?] 2022-04-21 17:42:40 source > at sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597) ~[?:?] 2022-04-21 17:42:40 source > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327) ~[?:?] 2022-04-21 17:42:40 source > at java.net.Socket.connect(Socket.java:633) ~[?:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.SocketStreamHelper.initialize(SocketStreamHelper.java:107) ~[mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.SocketStream.initializeSocket(SocketStream.java:79) ~[mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > at com.mongodb.internal.connection.SocketStream.open(SocketStream.java:65) ~[mongodb-driver-core-4.4.0.jar:?] 2022-04-21 17:42:40 source > ... 4 more 2022-04-21 17:43:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes) 2022-04-21 17:43:00 destination > 2022-04-21 17:43:00 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-04-21 17:43:00 destination > 2022-04-21 17:43:00 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-04-21 17:43:00 destination > 2022-04-21 17:43:00 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 0 current buffers (0 bytes in total) 2022-04-21 17:43:00 destination > 2022-04-21 17:43:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):182 - Copying into tables in destination started for 10 streams 2022-04-21 17:43:00 destination > 2022-04-21 17:43:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream _healthCheck of schema Auth into tmp table _airbyte_tmp_ssw__healthCheck to final table _airbyte_raw__healthCheck from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:01 destination > 2022-04-21 17:43:01 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream _queue of schema Auth into tmp table _airbyte_tmp_onp__queue to final table _airbyte_raw__queue from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:01 destination > 2022-04-21 17:43:01 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream _requestLogs of schema Auth into tmp table _airbyte_tmp_iyn__requestLogs to final table _airbyte_raw__requestLogs from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:02 destination > 2022-04-21 17:43:02 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream _scheduledTasks of schema Auth into tmp table _airbyte_tmp_pef__scheduledTasks to final table _airbyte_raw__scheduledTasks from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:02 destination > 2022-04-21 17:43:02 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream _systemSubscriptions of schema Auth into tmp table _airbyte_tmp_nyz__systemSubscriptions to final table _airbyte_raw__systemSubscriptions from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:03 destination > 2022-04-21 17:43:03 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream applications of schema Auth into tmp table _airbyte_tmp_qxj_applications to final table _airbyte_raw_applications from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:03 destination > 2022-04-21 17:43:03 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream auditLogins of schema Auth into tmp table _airbyte_tmp_czz_auditLogins to final table _airbyte_raw_auditLogins from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:04 destination > 2022-04-21 17:43:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream securityCodes of schema Auth into tmp table _airbyte_tmp_mma_securityCodes to final table _airbyte_raw_securityCodes from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:04 destination > 2022-04-21 17:43:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream tokens of schema Auth into tmp table _airbyte_tmp_ngx_tokens to final table _airbyte_raw_tokens from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:04 destination > 2022-04-21 17:43:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream users of schema Auth into tmp table _airbyte_tmp_muu_users to final table _airbyte_raw_users from stage path 2022/04/21/17/43246F1C-7D17-4159-A3D0-19E8A49F35A5/ with 0 file(s) [] 2022-04-21 17:43:05 destination > 2022-04-21 17:43:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):213 - Executing finalization of tables. 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Finalizing tables in destination completed. 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Cleaning up destination started for 10 streams 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream _healthCheck. schema Auth, tmp table name: _airbyte_tmp_ssw__healthCheck 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream _healthCheck. schema Auth, stage: AUTH__HEALTHCHECK 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream _queue. schema Auth, tmp table name: _airbyte_tmp_onp__queue 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream _queue. schema Auth, stage: AUTH__QUEUE 2022-04-21 17:43:07 destination > 2022-04-21 17:43:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream _requestLogs. schema Auth, tmp table name: _airbyte_tmp_iyn__requestLogs 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream _requestLogs. schema Auth, stage: AUTH__REQUESTLOGS 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream _scheduledTasks. schema Auth, tmp table name: _airbyte_tmp_pef__scheduledTasks 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream _scheduledTasks. schema Auth, stage: AUTH__SCHEDULEDTASKS 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream _systemSubscriptions. schema Auth, tmp table name: _airbyte_tmp_nyz__systemSubscriptions 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream _systemSubscriptions. schema Auth, stage: AUTH__SYSTEMSUBSCRIPTIONS 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream applications. schema Auth, tmp table name: _airbyte_tmp_qxj_applications 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream applications. schema Auth, stage: AUTH_APPLICATIONS 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream auditLogins. schema Auth, tmp table name: _airbyte_tmp_czz_auditLogins 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream auditLogins. schema Auth, stage: AUTH_AUDITLOGINS 2022-04-21 17:43:08 destination > 2022-04-21 17:43:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream securityCodes. schema Auth, tmp table name: _airbyte_tmp_mma_securityCodes 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream securityCodes. schema Auth, stage: AUTH_SECURITYCODES 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream tokens. schema Auth, tmp table name: _airbyte_tmp_ngx_tokens 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream tokens. schema Auth, stage: AUTH_TOKENS 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream users. schema Auth, tmp table name: _airbyte_tmp_muu_users 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream users. schema Auth, stage: AUTH_USERS 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning up destination completed. 2022-04-21 17:43:09 destination > 2022-04-21 17:43:09 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-04-21 17:43:10 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-04-21 17:43:10 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@51d3a62c[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650562948505,endTime=1650562990990,totalStats=io.airbyte.config.SyncStats@5503276d[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-04-21 17:43:10 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-21 17:43:10 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@772508a7[state={}] 2022-04-21 17:43:10 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-21 17:43:10 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@3835b364[standardSyncSummary=io.airbyte.config.StandardSyncSummary@af4ea48[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650562948505,endTime=1650562990990,totalStats=io.airbyte.config.SyncStats@5503276d[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@772508a7[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@332a373c[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@360a37b7[stream=io.airbyte.protocol.models.AirbyteStream@23311c81[name=_healthCheck,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"check":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@eba1405[stream=io.airbyte.protocol.models.AirbyteStream@6ccb5139[name=_queue,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"type":{"type":"string"},"message":{"type":"string"},"retryCount":{"type":"number"},"dateCreated":{"type":"string"},"rejectedTime":{"type":"string"},"releaseHistory":{"type":"array"},"rejectionReason":{"type":"string"},"nextReceivableTime":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@b9b7498[stream=io.airbyte.protocol.models.AirbyteStream@20e5b47e[name=_requestLogs,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"request":{"type":"string"},"duration":{"type":"number"},"endpoint":{"type":"string"},"response":{"type":"string"},"methodName":{"type":"string"},"requestType":{"type":"string"},"dateOfRequest":{"type":"string"},"dateOfResponse":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7e21865b[stream=io.airbyte.protocol.models.AirbyteStream@48d5523f[name=_scheduledTasks,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"cronSchedule":{"type":"string"},"executionLog":{"type":"array"},"lastCompletedTime":{"type":"string"},"nextScheduledTime":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@183ac009[stream=io.airbyte.protocol.models.AirbyteStream@15f1c134[name=_systemSubscriptions,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"entityType":{"type":"string"},"eventSubscription":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@67909e8f[stream=io.airbyte.protocol.models.AirbyteStream@5b66ce8[name=applications,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"key":{"type":"string"},"name":{"type":"string"},"secret":{"type":"string"},"domains":{"type":"array"},"allowedScopes":{"type":"array"},"requireWonscoreUser":{"type":"boolean"},"allowUnverifiedUsers":{"type":"boolean"},"allowedResourceScopes":{"type":"array"},"requireIcimsToolkitUser":{"type":"boolean"},"requireJobmaToolkitUser":{"type":"boolean"},"requireNewtonToolkitUser":{"type":"boolean"},"requireResearchToolkitUser":{"type":"boolean"},"requireWonscoreToolkitUser":{"type":"boolean"},"requireAcquiretmToolkitUser":{"type":"boolean"},"requireBizMerlinToolkitUser":{"type":"boolean"},"requireHiringThingToolkitUser":{"type":"boolean"},"requireApplicantproToolkitUser":{"type":"boolean"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4b42cedf[stream=io.airbyte.protocol.models.AirbyteStream@50a15ee2[name=auditLogins,jsonSchema={"type":"object","properties":{"ip":{"type":"string"},"_id":{"type":"string"},"_ts":{"type":"string"},"email":{"type":"string"},"osName":{"type":"string"},"userId":{"type":"string"},"isMobile":{"type":"boolean"},"osVersion":{"type":"string"},"userAgent":{"type":"string"},"browserName":{"type":"string"},"dateCreated":{"type":"string"},"fullVersion":{"type":"string"},"screenWidth":{"type":"number"},"windowWidth":{"type":"number"},"isSuccessful":{"type":"boolean"},"majorVersion":{"type":"number"},"screenHeight":{"type":"number"},"userLanguage":{"type":"string"},"windowHeight":{"type":"number"},"cookieEnabled":{"type":"boolean"},"cpuArchitecture":{"type":"string"},"screenColorDepth":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@33a6d69f[stream=io.airbyte.protocol.models.AirbyteStream@5412d2f[name=securityCodes,jsonSchema={"type":"object","properties":{}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@58282f6e[stream=io.airbyte.protocol.models.AirbyteStream@2243cc7[name=tokens,jsonSchema={"type":"object","properties":{"app":{"type":"string"},"user":{"type":"string"},"scope":{"type":"array"},"value":{"type":"string"},"expires":{"type":"string"},"token_type":{"type":"string"},"application":{"type":"string"},"_id_aibyte_transform":{"type":"string"},"impersonatedByUserId":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7330032[stream=io.airbyte.protocol.models.AirbyteStream@b177dae[name=users,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"_ts":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"logins":{"type":"string"},"changeId":{"type":"number"},"jobTitle":{"type":"string"},"lastName":{"type":"string"},"password":{"type":"string"},"verified":{"type":"boolean"},"changeLog":{"type":"array"},"firstName":{"type":"string"},"emailsSent":{"type":"array"},"verifyHash":{"type":"string"},"dateCreated":{"type":"string"},"toolkitRoles":{"type":"string"},"wonscoreUser":{"type":"boolean"},"oneTimeLogins":{"type":"array"},"invitationCode":{"type":"string"},"dateOfLastLogin":{"type":"string"},"eventSubscriptions":{"type":"array"},"invitationAcceptUrl":{"type":"string"},"dateOfCookiesConsent":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Auth,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@125d70fd[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@31bcb475[additionalProperties={attemptNumber=2, jobId=11}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 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.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1650562980710]]] 2022-04-21 17:43:10 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-21 17:43:11 INFO i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection 7cd7bf51-76e3-45ee-a03f-cb4f684a36e6 state: io.airbyte.config.State@635c3c04[state={}] 2022-04-21 17:43:11 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/11/2/logs.log 2022-04-21 17:43:11 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-04-21 17:43:11 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-04-21 17:43:11 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.75 2022-04-21 17:43:11 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.75 exists... 2022-04-21 17:43:11 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.75 was found locally. 2022-04-21 17:43:11 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 11 2022-04-21 17:43:11 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/11/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha airbyte/normalization-snowflake:0.1.75 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-04-21 17:43:11 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/11/2/normalize 2022-04-21 17:43:11 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/11/2/normalize') 2022-04-21 17:43:11 normalization > transform_snowflake 2022-04-21 17:43:11 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/11/2/normalize --catalog destination_catalog.json --out /data/11/2/normalize/models/generated/ --json-column _airbyte_data 2022-04-21 17:43:11 normalization > Processing destination_catalog.json... 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_HEALTHCHECK_AB1.sql from _healthCheck 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_HEALTHCHECK_AB2.sql from _healthCheck 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_HEALTHCHECK_AB3.sql from _healthCheck 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/_HEALTHCHECK.sql from _healthCheck 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_QUEUE_AB1.sql from _queue 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_QUEUE_AB2.sql from _queue 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_QUEUE_AB3.sql from _queue 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/_QUEUE.sql from _queue 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_REQUESTLOGS_AB1.sql from _requestLogs 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_REQUESTLOGS_AB2.sql from _requestLogs 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_REQUESTLOGS_AB3.sql from _requestLogs 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/_REQUESTLOGS.sql from _requestLogs 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SCHEDULEDTASKS_AB1.sql from _scheduledTasks 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SCHEDULEDTASKS_AB2.sql from _scheduledTasks 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SCHEDULEDTASKS_AB3.sql from _scheduledTasks 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/_SCHEDULEDTASKS.sql from _scheduledTasks 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SYSTEMSUBSCRIPTIONS_AB1.sql from _systemSubscriptions 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SYSTEMSUBSCRIPTIONS_AB2.sql from _systemSubscriptions 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/_SYSTEMSUBSCRIPTIONS_AB3.sql from _systemSubscriptions 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/_SYSTEMSUBSCRIPTIONS.sql from _systemSubscriptions 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/APPLICATIONS_AB1.sql from applications 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/APPLICATIONS_AB2.sql from applications 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/APPLICATIONS_AB3.sql from applications 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/APPLICATIONS.sql from applications 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/AUDITLOGINS_AB1.sql from auditLogins 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/AUDITLOGINS_AB2.sql from auditLogins 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/AUDITLOGINS_AB3.sql from auditLogins 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/AUDITLOGINS.sql from auditLogins 2022-04-21 17:43:11 normalization > Ignoring stream 'securityCodes' from securityCodes because properties list is empty 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/TOKENS_AB1.sql from tokens 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/TOKENS_AB2.sql from tokens 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/TOKENS_AB3.sql from tokens 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/TOKENS.sql from tokens 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/USERS_AB1.sql from users 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/USERS_AB2.sql from users 2022-04-21 17:43:11 normalization > Generating airbyte_ctes/AUTH/USERS_AB3.sql from users 2022-04-21 17:43:11 normalization > Generating airbyte_incremental/AUTH/USERS.sql from users 2022-04-21 17:43:11 normalization > detected no config file for ssh, assuming ssh is off. 2022-04-21 17:43:13 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-04-21 17:43:13 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-04-21 17:43:13 normalization > 2022-04-21 17:43:13 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-04-21 17:43:13 normalization > 2022-04-21 17:43:16 normalization > 17:43:16 Running with dbt=1.0.0 2022-04-21 17:43:16 normalization > 17:43:16 Partial parse save file not found. Starting full parse. 2022-04-21 17:43:17 normalization > 17:43:17 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-21 17:43:17 normalization > There are 2 unused configuration paths: 2022-04-21 17:43:17 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-04-21 17:43:17 normalization > - models.airbyte_utils.generated.airbyte_views 2022-04-21 17:43:17 normalization > 2022-04-21 17:43:17 normalization > 17:43:17 Found 36 models, 0 tests, 0 snapshots, 0 analyses, 528 macros, 0 operations, 0 seed files, 10 sources, 0 exposures, 0 metrics 2022-04-21 17:43:17 normalization > 17:43:17 2022-04-21 17:43:19 normalization > 17:43:19 Concurrency: 5 threads (target='prod') 2022-04-21 17:43:19 normalization > 17:43:19 2022-04-21 17:43:27 normalization > 17:43:27 1 of 9 START incremental model AUTH.APPLICATIONS........................................................................ [RUN] 2022-04-21 17:43:29 normalization > 17:43:29 2 of 9 START incremental model AUTH.USERS............................................................................... [RUN] 2022-04-21 17:43:29 normalization > 17:43:29 3 of 9 START incremental model AUTH._HEALTHCHECK........................................................................ [RUN] 2022-04-21 17:43:29 normalization > 17:43:29 4 of 9 START incremental model AUTH.TOKENS.............................................................................. [RUN] 2022-04-21 17:43:29 normalization > 17:43:29 5 of 9 START incremental model AUTH.AUDITLOGINS......................................................................... [RUN] 2022-04-21 17:43:31 normalization > 17:43:31 1 of 9 OK created incremental model AUTH.APPLICATIONS................................................................... [SUCCESS 1 in 4.20s] 2022-04-21 17:43:31 normalization > 17:43:31 6 of 9 START incremental model AUTH._QUEUE.............................................................................. [RUN] 2022-04-21 17:43:32 normalization > 17:43:32 2 of 9 OK created incremental model AUTH.USERS.......................................................................... [SUCCESS 1 in 3.11s] 2022-04-21 17:43:32 normalization > 17:43:32 7 of 9 START incremental model AUTH._SYSTEMSUBSCRIPTIONS................................................................ [RUN] 2022-04-21 17:43:32 normalization > 17:43:32 3 of 9 OK created incremental model AUTH._HEALTHCHECK................................................................... [SUCCESS 1 in 3.03s] 2022-04-21 17:43:32 normalization > 17:43:32 8 of 9 START incremental model AUTH._SCHEDULEDTASKS..................................................................... [RUN] 2022-04-21 17:43:32 normalization > 17:43:32 4 of 9 OK created incremental model AUTH.TOKENS......................................................................... [SUCCESS 1 in 3.15s] 2022-04-21 17:43:32 normalization > 17:43:32 9 of 9 START incremental model AUTH._REQUESTLOGS........................................................................ [RUN] 2022-04-21 17:43:33 normalization > 17:43:33 5 of 9 OK created incremental model AUTH.AUDITLOGINS.................................................................... [SUCCESS 1 in 3.34s] 2022-04-21 17:43:34 normalization > 17:43:34 6 of 9 OK created incremental model AUTH._QUEUE......................................................................... [SUCCESS 1 in 2.97s] 2022-04-21 17:43:34 normalization > 17:43:34 7 of 9 OK created incremental model AUTH._SYSTEMSUBSCRIPTIONS........................................................... [SUCCESS 1 in 2.78s] 2022-04-21 17:43:35 normalization > 17:43:35 8 of 9 OK created incremental model AUTH._SCHEDULEDTASKS................................................................ [SUCCESS 1 in 2.66s] 2022-04-21 17:43:35 normalization > 17:43:35 9 of 9 OK created incremental model AUTH._REQUESTLOGS................................................................... [SUCCESS 1 in 2.61s] 2022-04-21 17:43:35 normalization > 17:43:35 2022-04-21 17:43:35 normalization > 17:43:35 Finished running 9 incremental models in 17.42s. 2022-04-21 17:43:35 normalization > 17:43:35 2022-04-21 17:43:35 normalization > 17:43:35 Completed successfully 2022-04-21 17:43:35 normalization > 17:43:35 2022-04-21 17:43:35 normalization > 17:43:35 Done. PASS=9 WARN=0 ERROR=0 SKIP=0 TOTAL=9 2022-04-21 17:43:35 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 24 seconds. 2022-04-21 17:43:35 INFO i.a.w.DefaultNormalizationWorker(run):77 - Normalization summary: io.airbyte.config.NormalizationSummary@3f224125[startTime=1650562991078,endTime=1650563015680] 2022-04-21 17:43:35 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-21 17:43:35 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-21 17:43:35 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required 2022-04-21 17:43:35 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard]