2022-09-06 11:22:27 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-09-06 11:22:27 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.private_key: is missing but it is required 2022-09-06 11:22:27 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2022-09-06 11:22:27 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-09-06 11:22:27 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/513/0/logs.log 2022-09-06 11:22:27 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.4 2022-09-06 11:22:27 INFO i.a.c.i.LineGobbler(voidCall):83 - Checking if airbyte/source-intercom:0.1.25 exists... 2022-09-06 11:22:27 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-intercom-check-513-0-uzegs with resources io.airbyte.config.ResourceRequirements@45d32a51[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-09-06 11:22:27 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/513/0 --log-driver none --name source-intercom-check-513-0-uzegs --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-intercom:0.1.25 -e AIRBYTE_VERSION=0.40.4 -e WORKER_JOB_ID=513 airbyte/source-intercom:0.1.25 check --config source_config.json 2022-09-06 11:22:27 INFO i.a.c.i.LineGobbler(voidCall):83 - airbyte/source-intercom:0.1.25 was found locally. 2022-09-06 11:22:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded 2022-09-06 11:22:30 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling... 2022-09-06 11:22:30 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/513/0/logs.log 2022-09-06 11:22:30 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.4 2022-09-06 11:22:30 INFO i.a.c.i.LineGobbler(voidCall):83 - Checking if airbyte/destination-snowflake:0.4.35 exists... 2022-09-06 11:22:30 INFO i.a.c.i.LineGobbler(voidCall):83 - airbyte/destination-snowflake:0.4.35 was found locally. 2022-09-06 11:22:30 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-check-513-0-yakhe with resources io.airbyte.config.ResourceRequirements@45d32a51[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-09-06 11:22:30 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/513/0 --log-driver none --name destination-snowflake-check-513-0-yakhe --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.35 -e AIRBYTE_VERSION=0.40.4 -e WORKER_JOB_ID=513 airbyte/destination-snowflake:0.4.35 check --config source_config.json 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-09-06 11:22:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:32 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-09-06 11:22:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:34 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@68ac9ec5 2022-09-06 11:22:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:34 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-09-06 11:22:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:34 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-09-06 11:22:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:35 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-09-06 11:22:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:35 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-09-06 11:22:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-09-06 11:22:35 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-09-06 11:22:36 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling... 2022-09-06 11:22:36 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/513/0/logs.log 2022-09-06 11:22:36 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.4 2022-09-06 11:22:36 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):49 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-09-06 11:22:36 INFO i.a.c.EnvConfigs(getEnvOrDefault):1092 - Using default value for environment variable METRIC_CLIENT: '' 2022-09-06 11:22:36 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2022-09-06 11:22:36 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):49 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-09-06 11:22:36 INFO i.a.w.g.DefaultReplicationWorker(run):119 - start sync worker. job id: 513 attempt id: 0 2022-09-06 11:22:36 INFO i.a.w.g.DefaultReplicationWorker(run):131 - configured sync modes: {} 2022-09-06 11:22:36 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-09-06 11:22:36 INFO i.a.c.i.LineGobbler(voidCall):83 - Checking if airbyte/destination-snowflake:0.4.35 exists... 2022-09-06 11:22:37 INFO i.a.c.i.LineGobbler(voidCall):83 - airbyte/destination-snowflake:0.4.35 was found locally. 2022-09-06 11:22:37 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-write-513-0-nsfem with resources io.airbyte.config.ResourceRequirements@600c0ccf[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-09-06 11:22:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/513/0 --log-driver none --name destination-snowflake-write-513-0-nsfem --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.35 -e AIRBYTE_VERSION=0.40.4 -e WORKER_JOB_ID=513 airbyte/destination-snowflake:0.4.35 write --config destination_config.json --catalog destination_catalog.json 2022-09-06 11:22:37 INFO i.a.c.i.LineGobbler(voidCall):83 - Checking if airbyte/source-intercom:0.1.25 exists... 2022-09-06 11:22:37 INFO i.a.c.i.LineGobbler(voidCall):83 - airbyte/source-intercom:0.1.25 was found locally. 2022-09-06 11:22:37 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-intercom-read-513-0-ansey with resources io.airbyte.config.ResourceRequirements@816bb34[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-09-06 11:22:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/513/0 --log-driver none --name source-intercom-read-513-0-ansey --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-intercom:0.1.25 -e AIRBYTE_VERSION=0.40.4 -e WORKER_JOB_ID=513 airbyte/source-intercom:0.1.25 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-09-06 11:22:37 INFO i.a.w.g.DefaultReplicationWorker(run):173 - Waiting for source and destination threads to complete. 2022-09-06 11:22:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):421 - Destination output thread started. 2022-09-06 11:22:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):313 - Replication thread started. 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):116 - Preparing tmp tables in destination started for 0 streams 2022-09-06 11:22:39 destination > 2022-09-06 11:22:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):134 - Preparing tmp tables in destination completed. 2022-09-06 11:22:39 source > Starting syncing SourceIntercom 2022-09-06 11:22:39 source > Using start_date: 1605484800.0 2022-09-06 11:22:39 source > Finished syncing SourceIntercom 2022-09-06 11:22:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):342 - Source has no more messages, closing connection. 2022-09-06 11:22:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):350 - Total records read: 0 (0 bytes) 2022-09-06 11:22:40 INFO i.a.w.g.DefaultReplicationWorker(run):178 - One of source or destination thread complete. Waiting on the other. 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):62 - Airbyte message consumer: succeeded. 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure. 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):100 - Flushing all 0 current buffers (0 bytes in total) 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$3):181 - Copying into tables in destination started for 0 streams 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination. 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$3):211 - Executing finalization of tables. 2022-09-06 11:22:40 destination > 2022-09-06 11:22:40 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-09-06 11:22:41 destination > 2022-09-06 11:22:41 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@51b01550 2022-09-06 11:22:41 destination > 2022-09-06 11:22:41 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-09-06 11:22:42 destination > 2022-09-06 11:22:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$3):213 - Finalizing tables in destination completed. 2022-09-06 11:22:42 destination > 2022-09-06 11:22:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$3):215 - Cleaning up destination started for 0 streams 2022-09-06 11:22:42 destination > 2022-09-06 11:22:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$3):230 - Cleaning up destination completed. 2022-09-06 11:22:42 destination > 2022-09-06 11:22:42 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-09-06 11:22:43 INFO i.a.w.g.DefaultReplicationWorker(run):180 - Source and destination threads complete. 2022-09-06 11:22:43 INFO i.a.w.g.DefaultReplicationWorker(run):249 - sync summary: io.airbyte.config.ReplicationAttemptSummary@7d335f94[status=completed,recordsSynced=0,bytesSynced=0,startTime=1662463356910,endTime=1662463363500,totalStats=io.airbyte.config.SyncStats@40439afa[recordsEmitted=0,bytesEmitted=0,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,additionalProperties={}],streamStats=[]] 2022-09-06 11:22:43 INFO i.a.w.g.DefaultReplicationWorker(run):278 - Source did not output any state messages 2022-09-06 11:22:43 WARN i.a.w.g.DefaultReplicationWorker(run):286 - State capture: No new state, falling back on input state: io.airbyte.config.State@56ed254b[state={}] 2022-09-06 11:22:43 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling... 2022-09-06 11:22:43 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):166 - sync summary: io.airbyte.config.StandardSyncOutput@516cdb6c[standardSyncSummary=io.airbyte.config.StandardSyncSummary@64d43edb[status=completed,recordsSynced=0,bytesSynced=0,startTime=1662463356910,endTime=1662463363500,totalStats=io.airbyte.config.SyncStats@40439afa[recordsEmitted=0,bytesEmitted=0,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,additionalProperties={}],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@56ed254b[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7cf02f4d[streams=[],additionalProperties={}],failures=[]] 2022-09-06 11:22:43 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):312 - Stopping temporal heartbeating...