2022-06-28 16:03: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-06-28 16:03:24 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2022-06-28 16:03:24 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-06-28 16:03:24 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/10162/0/logs.log 2022-06-28 16:03:24 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.16-alpha 2022-06-28 16:03:24 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-bamboo-hr:0.2.0 exists... 2022-06-28 16:03:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-bamboo-hr:0.2.0 was found locally. 2022-06-28 16:03:25 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 10162 2022-06-28 16:03:25 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/10162/0 --log-driver none --name source-bamboo-hr-check-10162-0-jiaoo --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-bamboo-hr:0.2.0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.16-alpha -e WORKER_JOB_ID=10162 airbyte/source-bamboo-hr:0.2.0 check --config source_config.json 2022-06-28 16:03:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded 2022-06-28 16:03:26 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-28 16:03:27 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/10162/0/logs.log 2022-06-28 16:03:27 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.16-alpha 2022-06-28 16:03:27 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.28 exists... 2022-06-28 16:03:27 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.28 was found locally. 2022-06-28 16:03:27 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 10162 2022-06-28 16:03:27 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/10162/0 --log-driver none --name destination-snowflake-check-10162-0-vbaef --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.28 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.16-alpha -e WORKER_JOB_ID=10162 airbyte/destination-snowflake:0.4.28 check --config source_config.json 2022-06-28 16:03:28 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-06-28 16:03:28 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-06-28 16:03:28 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-06-28 16:03:28 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-06-28 16:03:28 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-28 16:03:28 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03: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-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03: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-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03: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-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03: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-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-06-28 16:03:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:29 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-06-28 16:03:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:31 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@60c73e58 2022-06-28 16:03:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:31 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-06-28 16:03:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-06-28 16:03:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:31 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-06-28 16:03:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-28 16:03:36 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-06-28 16:03:36 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-28 16:03:36 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/10162/0/logs.log 2022-06-28 16:03:36 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.16-alpha 2022-06-28 16:03:36 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 10162 attempt id: 0 2022-06-28 16:03:36 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.custom_reports_stream=full_refresh - overwrite} 2022-06-28 16:03:36 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-06-28 16:03:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.28 exists... 2022-06-28 16:03:36 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.28 was found locally. 2022-06-28 16:03:36 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 10162 2022-06-28 16:03:36 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/10162/0 --log-driver none --name destination-snowflake-write-10162-0-rsdkd --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.28 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.16-alpha -e WORKER_JOB_ID=10162 airbyte/destination-snowflake:0.4.28 write --config destination_config.json --catalog destination_catalog.json 2022-06-28 16:03:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-bamboo-hr:0.2.0 exists... 2022-06-28 16:03:37 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-bamboo-hr:0.2.0 was found locally. 2022-06-28 16:03:37 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 10162 2022-06-28 16:03:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/10162/0 --log-driver none --name source-bamboo-hr-read-10162-0-kyvmr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-bamboo-hr:0.2.0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.16-alpha -e WORKER_JOB_ID=10162 airbyte/source-bamboo-hr:0.2.0 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-06-28 16:03:37 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete. 2022-06-28 16:03:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):395 - Destination output thread started. 2022-06-28 16:03:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started. 2022-06-28 16:03:38 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-06-28 16:03:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-28 16:03:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-28 16:03:38 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-06-28 16:03:38 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-06-28 16:03:38 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-06-28 16:03:38 source > Starting syncing SourceBambooHr 2022-06-28 16:03:38 source > Syncing stream: custom_reports_stream 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-06-28 16:03:39 destination > 2022-06-28 16:03: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-06-28 16:03:39 destination > 2022-06-28 16:03: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-06-28 16:03:39 destination > 2022-06-28 16:03: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-06-28 16:03:39 destination > 2022-06-28 16:03: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-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-06-28 16:03:39 source > Read 208 records from custom_reports_stream stream 2022-06-28 16:03:39 source > Finished syncing custom_reports_stream 2022-06-28 16:03:39 source > SourceBambooHr runtimes: Syncing stream custom_reports_stream 0:00:01.260685 2022-06-28 16:03:39 source > Finished syncing SourceBambooHr 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=custom_reports_stream, namespace=BAMBOOHR, outputSchemaName=BAMBOOHR, tmpTableName=_airbyte_tmp_okl_custom_reports_stream, outputTableName=_airbyte_raw_custom_reports_stream, syncMode=overwrite} 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 1 streams 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema BAMBOOHR stream custom_reports_stream: tmp table: _airbyte_tmp_okl_custom_reports_stream, stage: 2022/06/28/16/3F50A541-3EA7-43BB-A795-43ACEA29E649/ 2022-06-28 16:03:39 destination > 2022-06-28 16:03:39 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-06-28 16:03:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):347 - Source has no more messages, closing connection. 2022-06-28 16:03:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):355 - Total records read: 208 (193 KB) 2022-06-28 16:03:39 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other. 2022-06-28 16:03:40 destination > 2022-06-28 16:03:40 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@2489e84a 2022-06-28 16:03:40 destination > 2022-06-28 16:03:40 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema BAMBOOHR stream custom_reports_stream 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed. 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream custom_reports_stream (current state: 0 bytes in 0 buffers) 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):241 - The main thread is exiting while children non-daemon threads from a connector are still active. 2022-06-28 16:03:41 destination > Ideally, this situation should not happen... 2022-06-28 16:03:41 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead. 2022-06-28 16:03:41 destination > The main thread is: main (RUNNABLE) 2022-06-28 16:03:41 destination > Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:276) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:245) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:202) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:165) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:165) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) 2022-06-28 16:03:41 destination > at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30) 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):255 - Active non-daemon thread: pool-4-thread-1 (TIMED_WAITING) 2022-06-28 16:03:41 destination > Thread stacktrace: java.base@17.0.1/jdk.internal.misc.Unsafe.park(Native Method) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:252) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1672) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:460) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1061) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1122) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 2022-06-28 16:03:41 destination > at java.base@17.0.1/java.lang.Thread.run(Thread.java:833) 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 1 current buffers (0 bytes in total) 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream custom_reports_stream (10 bytes) 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream custom_reports_stream (10 bytes) to staging 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data. 2022-06-28 16:03:41 destination > 2022-06-28 16:03:41 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 74a598a7-f5d4-4600-9d8e-457ab5e9b5b73057593819131137720.csv.gz (17 KB) 2022-06-28 16:03:42 destination > 2022-06-28 16:03:42 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-06-28 16:03:42 destination > 2022-06-28 16:03:42 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 74a598a7-f5d4-4600-9d8e-457ab5e9b5b73057593819131137720.csv.gz 2022-06-28 16:03:42 destination > 2022-06-28 16:03:42 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream custom_reports_stream 2022-06-28 16:03:42 destination > 2022-06-28 16:03:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 1 streams 2022-06-28 16:03:42 destination > 2022-06-28 16:03:42 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream custom_reports_stream of schema BAMBOOHR into tmp table _airbyte_tmp_okl_custom_reports_stream to final table _airbyte_raw_custom_reports_stream from stage path 2022/06/28/16/3F50A541-3EA7-43BB-A795-43ACEA29E649/ with 1 file(s) [74a598a7-f5d4-4600-9d8e-457ab5e9b5b73057593819131137720.csv.gz] 2022-06-28 16:03:44 destination > 2022-06-28 16:03:44 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):138 - No onDestinationCloseOperations required for this destination. 2022-06-28 16:03:44 destination > 2022-06-28 16:03:44 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Executing finalization of tables. 2022-06-28 16:03:46 destination > 2022-06-28 16:03:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):219 - Finalizing tables in destination completed. 2022-06-28 16:03:46 destination > 2022-06-28 16:03:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning up destination started for 1 streams 2022-06-28 16:03:46 destination > 2022-06-28 16:03:46 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream custom_reports_stream. schema BAMBOOHR, tmp table name: _airbyte_tmp_okl_custom_reports_stream 2022-06-28 16:03:47 destination > 2022-06-28 16:03:47 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream custom_reports_stream. schema BAMBOOHR, stage: BAMBOOHR_CUSTOM_REPORTS_STREAM 2022-06-28 16:03:47 destination > 2022-06-28 16:03:47 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):236 - Cleaning up destination completed. 2022-06-28 16:03:47 destination > 2022-06-28 16:03:47 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-06-28 16:03:48 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete. 2022-06-28 16:03:48 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@57666750[status=completed,recordsSynced=208,bytesSynced=198069,startTime=1656432216852,endTime=1656432228616,totalStats=io.airbyte.config.SyncStats@1041625[recordsEmitted=208,bytesEmitted=198069,stateMessagesEmitted=0,recordsCommitted=208],streamStats=[io.airbyte.config.StreamSyncStats@285877ad[streamName=custom_reports_stream,stats=io.airbyte.config.SyncStats@36bb24e5[recordsEmitted=208,bytesEmitted=198069,stateMessagesEmitted=,recordsCommitted=208]]]] 2022-06-28 16:03:48 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-06-28 16:03:48 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@52039985[state={}] 2022-06-28 16:03:48 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-28 16:03:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@434369cb[standardSyncSummary=io.airbyte.config.StandardSyncSummary@641ffc7[status=completed,recordsSynced=208,bytesSynced=198069,startTime=1656432216852,endTime=1656432228616,totalStats=io.airbyte.config.SyncStats@1041625[recordsEmitted=208,bytesEmitted=198069,stateMessagesEmitted=0,recordsCommitted=208],streamStats=[io.airbyte.config.StreamSyncStats@285877ad[streamName=custom_reports_stream,stats=io.airbyte.config.SyncStats@36bb24e5[recordsEmitted=208,bytesEmitted=198069,stateMessagesEmitted=,recordsCommitted=208]]]],normalizationSummary=,state=io.airbyte.config.State@52039985[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@177e9b6e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@378d5f68[stream=io.airbyte.protocol.models.AirbyteStream@6f586563[name=custom_reports_stream,jsonSchema={"type":["null","object"],"required":[],"properties":{"id":{"type":["null","string"]},"age":{"type":["null","string"]},"eeo":{"type":["null","string"]},"nin":{"type":["null","string"]},"sin":{"type":["null","string"]},"ssn":{"type":["null","string"]},"city":{"type":["null","string"]},"SQUAD":{"type":["null","string"]},"Squad":{"type":["null","string"]},"state":{"type":["null","string"]},"exempt":{"type":["null","string"]},"gender":{"type":["null","string"]},"status":{"type":["null","string"]},"country":{"type":["null","string"]},"paidPer":{"type":["null","string"]},"payRate":{"type":["null","string"]},"payType":{"type":["null","string"]},"zipcode":{"type":["null","string"]},"address1":{"type":["null","string"]},"address2":{"type":["null","string"]},"birthday":{"type":["null","string"]},"division":{"type":["null","string"]},"flsaCode":{"type":["null","string"]},"hireDate":{"type":["null","string"]},"hiredate":{"type":["null","string"]},"jobTitle":{"type":["null","string"]},"lastName":{"type":["null","string"]},"location":{"type":["null","string"]},"payGroup":{"type":["null","string"]},"acaStatus":{"type":["null","string"]},"bestEmail":{"type":["null","string"]},"bonusDate":{"type":["null","string"]},"ethnicity":{"type":["null","string"]},"firstName":{"type":["null","string"]},"fullName1":{"type":["null","string"]},"fullName2":{"type":["null","string"]},"fullName3":{"type":["null","string"]},"fullName4":{"type":["null","string"]},"fullName5":{"type":["null","string"]},"homeEmail":{"type":["null","string"]},"homePhone":{"type":["null","string"]},"stateCode":{"type":["null","string"]},"workEmail":{"type":["null","string"]},"workPhone":{"type":["null","string"]},"department":{"type":["null","string"]},"middleName":{"type":["null","string"]},"nationalId":{"type":["null","string"]},"payGroupId":{"type":["null","string"]},"supervisor":{"type":["null","string"]},"bonusAmount":{"type":["null","string"]},"bonusReason":{"type":["null","string"]},"dateOfBirth":{"type":["null","string"]},"displayName":{"type":["null","string"]},"lastChanged":{"type":["null","string"]},"mobilePhone":{"type":["null","string"]},"nationality":{"type":["null","string"]},"paySchedule":{"type":["null","string"]},"bonusComment":{"type":["null","string"]},"payFrequency":{"type":["null","string"]},"supervisorId":{"type":["null","string"]},"commisionDate":{"type":["null","string"]},"maritalStatus":{"type":["null","string"]},"payScheduleId":{"type":["null","string"]},"preferredName":{"type":["null","string"]},"supervisorEId":{"type":["null","string"]},"commissionDate":{"type":["null","string"]},"employeeNumber":{"type":["null","string"]},"createdByUserId":{"type":["null","string"]},"isPhotoUploaded":{"type":["null","string"]},"payChangeReason":{"type":["null","string"]},"supervisorEmail":{"type":["null","string"]},"terminationDate":{"type":["null","string"]},"commissionAmount":{"type":["null","string"]},"includeInPayroll":{"type":["null","string"]},"originalHireDate":{"type":["null","string"]},"acaStatusCategory":{"type":["null","string"]},"commissionComment":{"type":["null","string"]},"workPhoneExtension":{"type":["null","string"]},"timeTrackingEnabled":{"type":["null","string"]},"payRateEffectiveDate":{"type":["null","string"]},"standardHoursPerWeek":{"type":["null","string"]},"workPhonePlusExtension":{"type":["null","string"]},"employmentHistoryStatus":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=BAMBOOHR,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-06-28 16:03:48 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-06-28 16:03:48 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection 6b81ee7d-9e58-4e7b-b3f9-64260731a3b8 state: io.airbyte.config.State@58033b12[state={}] 2022-06-28 16:03:48 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/10162/0/logs.log 2022-06-28 16:03:48 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.16-alpha 2022-06-28 16:03:48 INFO i.a.w.g.DefaultNormalizationWorker(run):49 - Running normalization. 2022-06-28 16:03:48 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.2.1 2022-06-28 16:03:48 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.2.1 exists... 2022-06-28 16:03:48 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.2.1 was found locally. 2022-06-28 16:03:48 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 10162 2022-06-28 16:03:48 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/10162/0/normalize --log-driver none --name normalization-snowflake-normalize-10162-0-cjqyn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.16-alpha airbyte/normalization-snowflake:0.2.1 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-06-28 16:03:49 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/10162/0/normalize 2022-06-28 16:03:50 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/10162/0/normalize') 2022-06-28 16:03:50 normalization > transform_snowflake 2022-06-28 16:03:50 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/10162/0/normalize --catalog destination_catalog.json --out /data/10162/0/normalize/models/generated/ --json-column _airbyte_data 2022-06-28 16:03:50 normalization > Processing destination_catalog.json... 2022-06-28 16:03:50 normalization > Generating airbyte_ctes/BAMBOOHR/CUSTOM_REPORTS_STREAM_AB1.sql from custom_reports_stream 2022-06-28 16:03:50 normalization > Generating airbyte_ctes/BAMBOOHR/CUSTOM_REPORTS_STREAM_AB2.sql from custom_reports_stream 2022-06-28 16:03:50 normalization > Generating airbyte_ctes/BAMBOOHR/CUSTOM_REPORTS_STREAM_AB3.sql from custom_reports_stream 2022-06-28 16:03:50 normalization > Generating airbyte_tables/BAMBOOHR/CUSTOM_REPORTS_STREAM.sql from custom_reports_stream 2022-06-28 16:03:50 normalization > detected no config file for ssh, assuming ssh is off. 2022-06-28 16:03:53 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-06-28 16:03:53 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-06-28 16:03:53 normalization > 2022-06-28 16:03:53 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-06-28 16:03:53 normalization > 2022-06-28 16:03:56 normalization > 16:03:56 Running with dbt=1.0.0 2022-06-28 16:03:56 normalization > 16:03:56 Partial parse save file not found. Starting full parse. 2022-06-28 16:03:57 normalization > 16:03:57 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-06-28 16:03:57 normalization > There are 2 unused configuration paths: 2022-06-28 16:03:57 normalization > - models.airbyte_utils.generated.airbyte_views 2022-06-28 16:03:57 normalization > - models.airbyte_utils.generated.airbyte_incremental 2022-06-28 16:03:57 normalization > 2022-06-28 16:03:57 normalization > 16:03:57 Found 4 models, 0 tests, 0 snapshots, 0 analyses, 535 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-06-28 16:03:57 normalization > 16:03:57 2022-06-28 16:04:00 normalization > 16:04:00 Concurrency: 5 threads (target='prod') 2022-06-28 16:04:00 normalization > 16:04:00 2022-06-28 16:04:01 normalization > 16:04:01 1 of 1 START table model BAMBOOHR.CUSTOM_REPORTS_STREAM................................................................. [RUN] 2022-06-28 16:04:04 normalization > 16:04:04 1 of 1 OK created table model BAMBOOHR.CUSTOM_REPORTS_STREAM............................................................ [SUCCESS 1 in 3.10s] 2022-06-28 16:04:04 normalization > 16:04:04 2022-06-28 16:04:04 normalization > 16:04:04 Finished running 1 table model in 6.97s. 2022-06-28 16:04:04 normalization > 16:04:04 2022-06-28 16:04:04 normalization > 16:04:04 Completed successfully 2022-06-28 16:04:04 normalization > 16:04:04 2022-06-28 16:04:04 normalization > 16:04:04 Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1 2022-06-28 16:04:05 INFO i.a.w.g.DefaultNormalizationWorker(run):73 - Normalization executed in 16 seconds. 2022-06-28 16:04:05 INFO i.a.w.g.DefaultNormalizationWorker(run):79 - Normalization summary: io.airbyte.config.NormalizationSummary@45c90398[startTime=1656432228755,endTime=1656432245696] 2022-06-28 16:04:05 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-06-28 16:04:05 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...