2022-04-01 14:30:55 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.56-alpha
2022-04-01 14:30:55 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/6108/1/logs.log
2022-04-01 14:30:55 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.56-alpha
2022-04-01 14:30:55 [32mINFO[m i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 6108 attempt id: 1
2022-04-01 14:30:55 [32mINFO[m i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.employee=full_refresh - overwrite}
2022-04-01 14:30:55 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-01 14:30:55 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.24 exists...
2022-04-01 14:30:55 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.24 was found locally.
2022-04-01 14:30:55 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 6108
2022-04-01 14:30:55 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/6108/1 --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=1 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.56-alpha -e WORKER_JOB_ID=6108 airbyte/destination-snowflake:0.4.24 write --config destination_config.json --catalog destination_catalog.json
2022-04-01 14:30:55 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-bamboo-hr:0.2.0 exists...
2022-04-01 14:30:56 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-bamboo-hr:0.2.0 was found locally.
2022-04-01 14:30:56 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 6108
2022-04-01 14:30:56 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/6108/1 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-bamboo-hr:0.2.0 -e WORKER_JOB_ATTEMPT=1 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.56-alpha -e WORKER_JOB_ID=6108 airbyte/source-bamboo-hr:0.2.0 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-01 14:30:56 [32mINFO[m i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-01 14:30:56 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-01 14:30:56 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-01 14:30:56 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-01 14:30:56 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-01 14:30:56 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-01 14:30:56 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-01 14:30:56 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-01 14:30:57 [44msource[0m > Starting syncing SourceBambooHr
2022-04-01 14:30:57 [44msource[0m > "The requested stream employee was not found in the source. Available streams: dict_keys(['employees_directory_stream', 'custom_reports_stream'])"
Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 127, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 118, in run
    for message in generator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    f"The requested stream {configured_stream.stream.name} was not found in the source."
KeyError: "The requested stream employee was not found in the source. Available streams: dict_keys(['employees_directory_stream', 'custom_reports_stream'])"
2022-04-01 14:30:57 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes)
2022-04-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [33mWARN[m 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-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [33mWARN[m 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-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [33mWARN[m 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-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [33mWARN[m 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-01 14:30:57 [43mdestination[0m > 2022-04-01 14:30:57 [32mINFO[m i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [33mWARN[m i.a.i.d.s.SnowflakeDatabase(createDataSource):96 - Obsolete User/password login mode is used. Please re-create a connection to use the latest connector's version
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=employee, namespace=BAMBOOHR, outputSchemaName=BAMBOOHR, tmpTableName=_airbyte_tmp_wpn_employee, outputTableName=_airbyte_raw_employee, syncMode=overwrite}
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 1 streams
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema BAMBOOHR stream employee: tmp table: _airbyte_tmp_wpn_employee, stage: 2022/04/01/14/8C49D6F1-61E9-446B-ABB4-658773184F80/
2022-04-01 14:30:58 [43mdestination[0m > 2022-04-01 14:30:58 [32mINFO[m c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-04-01 14:30:59 [43mdestination[0m > 2022-04-01 14:30:59 [32mINFO[m c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@1ee47d9e
2022-04-01 14:30:59 [43mdestination[0m > 2022-04-01 14:30:59 [32mINFO[m c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-04-01 14:30:59 [43mdestination[0m > 2022-04-01 14:30:59 [32mINFO[m i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema BAMBOOHR stream employee
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed.
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-04-01 14:31:00 [43mdestination[0m > Ideally, this situation should not happen...
2022-04-01 14:31:00 [43mdestination[0m > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-04-01 14:31:00 [43mdestination[0m > The main thread is: main (RUNNABLE)
2022-04-01 14:31:00 [43mdestination[0m >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-01 14:31:00 [43mdestination[0m >         at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30)
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [33mWARN[m i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-4-thread-1 (RUNNABLE)
2022-04-01 14:31:00 [43mdestination[0m >  Thread stacktrace: java.base@17.0.1/sun.nio.ch.Net.poll(Native Method)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.park(NioSocketImpl.java:181)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.timedRead(NioSocketImpl.java:285)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:309)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/java.net.Socket$SocketInputStream.read(Socket.java:966)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:478)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:472)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1455)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1059)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.RestRequest.execute(RestRequest.java:160)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.core.HttpUtil.executeRequestInternal(HttpUtil.java:639)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.core.HttpUtil.executeRequest(HttpUtil.java:584)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.core.HttpUtil.executeGeneralRequest(HttpUtil.java:551)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.sendBatch(TelemetryClient.java:256)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.lambda$sendBatchAsync$0(TelemetryClient.java:204)
2022-04-01 14:31:00 [43mdestination[0m >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient$$Lambda$254/0x0000000800fbfc70.call(Unknown Source)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-01 14:31:00 [43mdestination[0m >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 0 current buffers (0 bytes in total)
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):182 - Copying into tables in destination started for 1 streams
2022-04-01 14:31:00 [43mdestination[0m > 2022-04-01 14:31:00 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):191 - Copying stream employee of schema BAMBOOHR into tmp table _airbyte_tmp_wpn_employee to final table _airbyte_raw_employee from stage path 2022/04/01/14/8C49D6F1-61E9-446B-ABB4-658773184F80/ with 0 file(s) []
2022-04-01 14:31:01 [43mdestination[0m > 2022-04-01 14:31:01 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):213 - Executing finalization of tables.
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Finalizing tables in destination completed.
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Cleaning up destination started for 1 streams
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning tmp table in destination started for stream employee. schema BAMBOOHR, tmp table name: _airbyte_tmp_wpn_employee
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):226 - Cleaning stage in destination started for stream employee. schema BAMBOOHR, stage: BAMBOOHR_EMPLOYEE
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):230 - Cleaning up destination completed.
2022-04-01 14:31:02 [43mdestination[0m > 2022-04-01 14:31:02 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-01 14:31:04 [1;31mERROR[m 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.35.56-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.56-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.56-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.35.56-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.56-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.56-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.56-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.35.56-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-01 14:31:04 [32mINFO[m i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@25c436f9[status=failed,recordsSynced=0,bytesSynced=0,startTime=1648823455889,endTime=1648823464270,totalStats=io.airbyte.config.SyncStats@261bf9b0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-04-01 14:31:04 [32mINFO[m i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-01 14:31:04 [33mWARN[m i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@2580ac23[state={}]
2022-04-01 14:31:04 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-01 14:31:04 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@250357bc[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2a069d57[status=failed,recordsSynced=0,bytesSynced=0,startTime=1648823455889,endTime=1648823464270,totalStats=io.airbyte.config.SyncStats@261bf9b0[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@2580ac23[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5d38326e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@7bf8596b[stream=io.airbyte.protocol.models.AirbyteStream@44f95f1f[name=employee,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"GPA":{"type":["null","string"]},"eeo":{"type":["null","string"]},"sin":{"type":["null","string"]},"ssn":{"type":["null","string"]},"Note":{"type":["null","string"]},"Type":{"type":["null","string"]},"Visa":{"type":["null","string"]},"city":{"type":["null","string"]},"Bonus":{"type":["null","string"]},"state":{"type":["null","string"]},"Amount":{"type":["null","string"]},"Assets":{"type":["null","string"]},"Degree":{"type":["null","string"]},"Issued":{"type":["null","string"]},"exempt":{"type":["null","string"]},"gender":{"type":["null","string"]},"payPer":{"type":["null","string"]},"status":{"type":["null","string"]},"Comment":{"type":["null","string"]},"country":{"type":["null","string"]},"payRate":{"type":["null","string"]},"payType":{"type":["null","string"]},"zipcode":{"type":["null","string"]},"Pay Date":{"type":["null","string"]},"address1":{"type":["null","string"]},"address2":{"type":["null","string"]},"division":{"type":["null","string"]},"facebook":{"type":["null","string"]},"hireDate":{"type":["null","string"]},"jobTitle":{"type":["null","string"]},"lastName":{"type":["null","string"]},"linkedIn":{"type":["null","string"]},"location":{"type":["null","string"]},"nickname":{"type":["null","string"]},"payGroup":{"type":["null","string"]},"pronouns":{"type":["null","string"]},"Passports":{"type":["null","string"]},"Visa:Date":{"type":["null","string"]},"acaStatus":{"type":["null","string"]},"bonusDate":{"type":["null","string"]},"ethnicity":{"type":["null","string"]},"firstName":{"type":["null","string"]},"homeEmail":{"type":["null","string"]},"homePhone":{"type":["null","string"]},"payPeriod":{"type":["null","string"]},"workEmail":{"type":["null","string"]},"workPhone":{"type":["null","string"]},"Commission":{"type":["null","string"]},"Expiration":{"type":["null","string"]},"department":{"type":["null","string"]},"middleName":{"type":["null","string"]},"bonusAmount":{"type":["null","string"]},"bonusReason":{"type":["null","string"]},"customSquad":{"type":["null","string"]},"dateOfBirth":{"type":["null","string"]},"mobilePhone":{"type":["null","string"]},"paySchedule":{"type":["null","string"]},"twitterFeed":{"type":["null","string"]},"Assets: Cost":{"type":["null","string"]},"Reporting to":{"type":["null","string"]},"Vesting Date":{"type":["null","string"]},"bonusComment":{"type":["null","string"]},"overtimeRate":{"type":["null","string"]},"Assets: Notes":{"type":["null","string"]},"Dependent SIN":{"type":["null","string"]},"Dependent SSN":{"type":["null","string"]},"Dependent ZIP":{"type":["null","string"]},"Sick - Policy":{"type":["null","string"]},"maritalStatus":{"type":["null","string"]},"preferredName":{"type":["null","string"]},"Dependent City":{"type":["null","string"]},"Veteran Status":{"type":["null","string"]},"commissionDate":{"type":["null","string"]},"customJobLevel":{"type":["null","string"]},"customTimeZone":{"type":["null","string"]},"employeeNumber":{"type":["null","string"]},"genderIdentity":{"type":["null","string"]},"Benefit History":{"type":["null","string"]},"Dependent State":{"type":["null","string"]},"Issuing Country":{"type":["null","string"]},"Issuing country":{"type":["null","string"]},"Passport Number":{"type":["null","string"]},"customAllergies":{"type":["null","string"]},"customEthnicity":{"type":["null","string"]},"customShirtSize":{"type":["null","string"]},"payChangeReason":{"type":["null","string"]},"terminationDate":{"type":["null","string"]},"Assets: Category":{"type":["null","string"]},"Completed - Cost":{"type":["null","string"]},"Dependent Gender":{"type":["null","string"]},"Net Equity Value":{"type":["null","string"]},"Termination Type":{"type":["null","string"]},"Vesting Schedule":{"type":["null","string"]},"Visa Information":{"type":["null","string"]},"commissionAmount":{"type":["null","string"]},"customCostCenter":{"type":["null","string"]},"employmentStatus":{"type":["null","string"]},"hoursPerPayCycle":{"type":["null","string"]},"originalHireDate":{"type":["null","string"]},"Completed - Hours":{"type":["null","string"]},"Completed - Notes":{"type":["null","string"]},"Completed - Title":{"type":["null","string"]},"Dependent Country":{"type":["null","string"]},"Vacation - Policy":{"type":["null","string"]},"commissionComment":{"type":["null","string"]},"Dependent Street 1":{"type":["null","string"]},"Dependent Street 2":{"type":["null","string"]},"Emergency Contacts":{"type":["null","string"]},"Gross Equity Value":{"type":["null","string"]},"Jury Duty - Policy":{"type":["null","string"]},"Termination Reason":{"type":["null","string"]},"employeeStatusDate":{"type":["null","string"]},"workPhoneExtension":{"type":["null","string"]},"Assets: Date Loaned":{"type":["null","string"]},"Assets: Description":{"type":["null","string"]},"College/Institution":{"type":["null","string"]},"Completed - Credits":{"type":["null","string"]},"Dependent Last Name":{"type":["null","string"]},"Self-service access":{"type":["null","string"]},"# of Options Granted":{"type":["null","string"]},"Bereavement - Policy":{"type":["null","string"]},"Completed - Category":{"type":["null","string"]},"Dependent Birth Date":{"type":["null","string"]},"Dependent First Name":{"type":["null","string"]},"Dependent Home Phone":{"type":["null","string"]},"Dependent US Citizen":{"type":["null","string"]},"Eligible For Re-hire":{"type":["null","string"]},"Major/Specialization":{"type":["null","string"]},"customGenderIdentity":{"type":["null","string"]},"payRateEffectiveDate":{"type":["null","string"]},"Assets: Date Returned":{"type":["null","string"]},"Assets: Serial Number":{"type":["null","string"]},"Compensation comments":{"type":["null","string"]},"Completed - Completed":{"type":["null","string"]},"Dependent Middle Name":{"type":["null","string"]},"Job Information: Date":{"type":["null","string"]},"Passport: Expiry Date":{"type":["null","string"]},"Passport: Issued Date":{"type":["null","string"]},"Sick - Days scheduled":{"type":["null","string"]},"Amount - Currency code":{"type":["null","string"]},"Completed - Instructor":{"type":["null","string"]},"Dependent Relationship":{"type":["null","string"]},"Emergency Contact City":{"type":["null","string"]},"Emergency Contact Name":{"type":["null","string"]},"Sick - Current balance":{"type":["null","string"]},"Sick - Policy Assigned":{"type":["null","string"]},"Emergency Contact Email":{"type":["null","string"]},"Emergency Contact State":{"type":["null","string"]},"Parental Leave - Policy":{"type":["null","string"]},"Sick - Days taken (YTD)":{"type":["null","string"]},"employmentHistoryStatus":{"type":["null","string"]},"Accrual Level Start Date":{"type":["null","string"]},"Sick - Adjustments (YTD)":{"type":["null","string"]},"Sick - Available Balance":{"type":["null","string"]},"Emergency Contact Country":{"type":["null","string"]},"Emergency Contact Primary":{"type":["null","string"]},"Sick - Accrual Start Date":{"type":["null","string"]},"Vacation - Days scheduled":{"type":["null","string"]},"customDietaryRestrictions":{"type":["null","string"]},"Emergency Contact Street 1":{"type":["null","string"]},"Emergency Contact Street 2":{"type":["null","string"]},"Emergency Contact Work Ext":{"type":["null","string"]},"Emergency Contact ZIP Code":{"type":["null","string"]},"Employment status comments":{"type":["null","string"]},"Jury Duty - Days scheduled":{"type":["null","string"]},"Vacation - Current balance":{"type":["null","string"]},"Vacation - Policy Assigned":{"type":["null","string"]},"Dependent Full-Time Student":{"type":["null","string"]},"Jury Duty - Current balance":{"type":["null","string"]},"Jury Duty - Policy Assigned":{"type":["null","string"]},"Vacation - Days taken (YTD)":{"type":["null","string"]},"Assets: Cost - Currency code":{"type":["null","string"]},"Bereavement - Days scheduled":{"type":["null","string"]},"Emergency Contact Home Phone":{"type":["null","string"]},"Emergency Contact Work Phone":{"type":["null","string"]},"Employee Education: End Date":{"type":["null","string"]},"Jury Duty - Days taken (YTD)":{"type":["null","string"]},"Vacation - Adjustments (YTD)":{"type":["null","string"]},"Vacation - Available Balance":{"type":["null","string"]},"Bereavement - Current balance":{"type":["null","string"]},"Bereavement - Policy Assigned":{"type":["null","string"]},"Jury Duty - Adjustments (YTD)":{"type":["null","string"]},"Jury Duty - Available Balance":{"type":["null","string"]},"Vacation - Accrual Start Date":{"type":["null","string"]},"Bereavement - Days taken (YTD)":{"type":["null","string"]},"Emergency Contact Mobile Phone":{"type":["null","string"]},"Emergency Contact Relationship":{"type":["null","string"]},"Employee Education: Start Date":{"type":["null","string"]},"Jury Duty - Accrual Start Date":{"type":["null","string"]},"Bereavement - Adjustments (YTD)":{"type":["null","string"]},"Bereavement - Available Balance":{"type":["null","string"]},"Parental Leave - Days scheduled":{"type":["null","string"]},"Bereavement - Accrual Start Date":{"type":["null","string"]},"Net Equity Value - Currency code":{"type":["null","string"]},"Parental Leave - Current balance":{"type":["null","string"]},"Parental Leave - Policy Assigned":{"type":["null","string"]},"Payroll Tax Operations - Expires":{"type":["null","string"]},"Maternity Leave policy - Assigned":{"type":["null","string"]},"Parental Leave - Days taken (YTD)":{"type":["null","string"]},"Payroll Tax Operations - Due Date":{"type":["null","string"]},"Floating Company Holidays - Policy":{"type":["null","string"]},"Gross Equity Value - Currency code":{"type":["null","string"]},"Parental Leave - Adjustments (YTD)":{"type":["null","string"]},"Parental Leave - Available Balance":{"type":["null","string"]},"Payroll Tax Operations - Completed":{"type":["null","string"]},"Maternity Leave policy - Started on":{"type":["null","string"]},"Parental Leave - Accrual Start Date":{"type":["null","string"]},"US Floating Holidays policy - Assigned":{"type":["null","string"]},"US Floating Holidays policy - Started on":{"type":["null","string"]},"Canada Floating Holiday policy - Assigned":{"type":["null","string"]},"Floating Company Holidays - Days scheduled":{"type":["null","string"]},"Canada Floating Holiday policy - Started on":{"type":["null","string"]},"Floating Company Holidays - Current balance":{"type":["null","string"]},"Floating Company Holidays - Policy Assigned":{"type":["null","string"]},"Floating Company Holidays - Days taken (YTD)":{"type":["null","string"]},"Floating Company Holidays - Adjustments (YTD)":{"type":["null","string"]},"Floating Company Holidays - Available Balance":{"type":["null","string"]},"Floating Company Holidays - Accrual Start Date":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=BAMBOOHR,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@5a0b8ef2[failureOrigin=source,failureType=<null>,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@463c7c9f[additionalProperties={attemptNumber=1, jobId=6108}],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=<null>,timestamp=1648823457309]]]
2022-04-01 14:31:04 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-01 14:31:04 [32mINFO[m i.a.c.p.ConfigRepository(updateConnectionState):494 - Updating connection a6ca35a7-18bd-4d84-9f38-f7e48cacf501 state: io.airbyte.config.State@774383a7[state={}]
2022-04-01 14:31:04 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/6108/1/logs.log
2022-04-01 14:31:04 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.56-alpha
2022-04-01 14:31:04 [32mINFO[m i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-01 14:31:04 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.71
2022-04-01 14:31:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.71 exists...
2022-04-01 14:31:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.71 was found locally.
2022-04-01 14:31:04 [32mINFO[m i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 6108
2022-04-01 14:31:04 [32mINFO[m i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/6108/1/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.35.56-alpha airbyte/normalization-snowflake:0.1.71 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-04-01 14:31:04 [42mnormalization[0m > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/6108/1/normalize
2022-04-01 14:31:05 [42mnormalization[0m > Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/6108/1/normalize')
2022-04-01 14:31:05 [42mnormalization[0m > transform_snowflake
2022-04-01 14:31:05 [42mnormalization[0m > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/6108/1/normalize --catalog destination_catalog.json --out /data/6108/1/normalize/models/generated/ --json-column _airbyte_data
2022-04-01 14:31:05 [42mnormalization[0m > Processing destination_catalog.json...
2022-04-01 14:31:05 [42mnormalization[0m >   Generating airbyte_ctes/BAMBOOHR/EMPLOYEE_AB1.sql from employee
2022-04-01 14:31:05 [42mnormalization[0m >   Generating airbyte_ctes/BAMBOOHR/EMPLOYEE_AB2.sql from employee
2022-04-01 14:31:05 [42mnormalization[0m >   Generating airbyte_ctes/BAMBOOHR/EMPLOYEE_AB3.sql from employee
2022-04-01 14:31:05 [42mnormalization[0m >   Generating airbyte_tables/BAMBOOHR/EMPLOYEE.sql from employee
2022-04-01 14:31:05 [42mnormalization[0m > detected no config file for ssh, assuming ssh is off.
2022-04-01 14:31:08 [42mnormalization[0m > 14:31:08  Running with dbt=1.0.0
2022-04-01 14:31:08 [42mnormalization[0m > 14:31:08  Partial parse save file not found. Starting full parse.
2022-04-01 14:31:09 [42mnormalization[0m > 14:31:09  [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-04-01 14:31:09 [42mnormalization[0m > There are 2 unused configuration paths:
2022-04-01 14:31:09 [42mnormalization[0m > - models.airbyte_utils.generated.airbyte_incremental
2022-04-01 14:31:09 [42mnormalization[0m > - models.airbyte_utils.generated.airbyte_views
2022-04-01 14:31:09 [42mnormalization[0m > 
2022-04-01 14:31:09 [42mnormalization[0m > 14:31:09  Found 4 models, 0 tests, 0 snapshots, 0 analyses, 526 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-04-01 14:31:09 [42mnormalization[0m > 14:31:09  
2022-04-01 14:31:11 [42mnormalization[0m > 14:31:11  Concurrency: 5 threads (target='prod')
2022-04-01 14:31:11 [42mnormalization[0m > 14:31:11  
2022-04-01 14:31:19 [42mnormalization[0m > 14:31:19  1 of 1 START table model BAMBOOHR.EMPLOYEE.............................................................................. [RUN]
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  1 of 1 OK created table model BAMBOOHR.EMPLOYEE......................................................................... [SUCCESS 1 in 3.10s]
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  Finished running 1 table model in 12.93s.
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  Completed successfully
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  
2022-04-01 14:31:22 [42mnormalization[0m > 14:31:22  Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2022-04-01 14:31:23 [32mINFO[m i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 18 seconds.
2022-04-01 14:31:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-01 14:31:23 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-01 14:31:23 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]