2022-07-06 17:26:44 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.11-alpha 2022-07-06 17:26:45 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/317/0/logs.log 2022-07-06 17:26:45 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.36.11-alpha 2022-07-06 17:26:45 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 317 attempt id: 0 2022-07-06 17:26:45 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.labor_groups=full_refresh - append} 2022-07-06 17:26:45 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-06 17:26:45 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery-denormalized:1.1.9 exists... 2022-07-06 17:26:45 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery-denormalized:1.1.9 was found locally. 2022-07-06 17:26:45 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 317 2022-07-06 17:26:45 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/317/0 --log-driver none --name destination-bigquery-denormalized-write-317-0-kqmwc --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery-denormalized:1.1.9 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.11-alpha -e WORKER_JOB_ID=317 airbyte/destination-bigquery-denormalized:1.1.9 write --config destination_config.json --catalog destination_catalog.json 2022-07-06 17:26:45 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-zenefits-test:1.0.0 exists... 2022-07-06 17:26:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-zenefits-test:1.0.0 was found locally. 2022-07-06 17:26:46 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 317 2022-07-06 17:26:46 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/317/0 --log-driver none --name source-zenefits-test-read-317-0-nhlto --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-zenefits-test:1.0.0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.11-alpha -e WORKER_JOB_ID=317 airbyte/source-zenefits-test:1.0.0 read --config source_config.json --catalog source_catalog.json 2022-07-06 17:26:46 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-07-06 17:26:46 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-07-06 17:26:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-07-06 17:26:46 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-07-06 17:26:46 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-06 17:26:46 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-06 17:26:46 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-06 17:26:46 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-06 17:26:46 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-06 17:26:46 destination > 2022-07-06 17:26:46 ERROR i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details. 2022-07-06 17:26:46 destination > java.lang.Exception: Verification error(s) occurred for WRITE. Errors: [$.loading_method.method: must be a constant value Standard] 2022-07-06 17:26:46 destination > at io.airbyte.integrations.base.IntegrationRunner.validateConfig(IntegrationRunner.java:282) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-07-06 17:26:46 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:162) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-07-06 17:26:46 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] 2022-07-06 17:26:46 destination > at io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination.main(BigQueryDenormalizedDestination.java:72) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-denormalized-0.39.20-alpha.jar:?] 2022-07-06 17:26:47 source > Starting syncing SourceZenefits 2022-07-06 17:26:47 source > Syncing stream: labor_groups 2022-07-06 17:27:47 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-07-06 17:27:47 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: java.io.IOException: Stream closed at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?] at java.io.OutputStream.write(OutputStream.java:162) ~[?:?] at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-07-06 17:27:47 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@3175e1c7[status=failed,recordsSynced=4,bytesSynced=18746,startTime=1657128405231,endTime=1657128467093,totalStats=io.airbyte.config.SyncStats@35871809[recordsEmitted=4,bytesEmitted=18746,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@4243cb4c[streamName=labor_groups,stats=io.airbyte.config.SyncStats@1370cc1d[recordsEmitted=4,bytesEmitted=18746,stateMessagesEmitted=,recordsCommitted=]]]] 2022-07-06 17:27:47 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-07-06 17:27:47 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained. 2022-07-06 17:27:47 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-06 17:27:47 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):155 - sync summary: io.airbyte.config.StandardSyncOutput@54531a9d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@11518e73[status=failed,recordsSynced=4,bytesSynced=18746,startTime=1657128405231,endTime=1657128467093,totalStats=io.airbyte.config.SyncStats@35871809[recordsEmitted=4,bytesEmitted=18746,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@4243cb4c[streamName=labor_groups,stats=io.airbyte.config.SyncStats@1370cc1d[recordsEmitted=4,bytesEmitted=18746,stateMessagesEmitted=,recordsCommitted=]]]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@1470a1ad[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@208a39af[stream=io.airbyte.protocol.models.AirbyteStream@6c4148d1[name=labor_groups,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["string","null"]},"url":{"type":["string","null"]},"code":{"type":["string","null"]},"name":{"type":["string","null"]},"object":{"type":["string","null"]},"assigned_members":{"type":"object","properties":{"url":{"type":["string","null"]},"data":{"type":["array","null"],"items":{"type":["object","null"],"properties":{"url":{"type":["string","null"]},"object":{"type":["string","null"]},"is_primary":{"type":["boolean","null"]},"ref_object":{"type":["string","null"]}}}},"object":{"type":["string","null"]},"next_url":{"type":["string","null"]}}},"labor_group_type":{"type":"object","properties":{"url":{"type":["string","null"]},"object":{"type":["string","null"]},"ref_object":{"type":["string","null"]}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=poke_api,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@717e713c[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@6012cb77[additionalProperties={attemptNumber=0, jobId=317}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed 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$DestinationException: Destination process message delivery failed at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: java.io.IOException: Stream closed at java.base/java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) at java.base/java.io.OutputStream.write(OutputStream.java:162) at java.base/java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233) at java.base/java.io.Writer.write(Writer.java:249) at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294) ... 4 more ,retryable=,timestamp=1657128411082], io.airbyte.config.FailureReason@1124c19b[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@774504ae[additionalProperties={attemptNumber=0, jobId=317}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination 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$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1657128407039]]] 2022-07-06 17:27:47 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-06 17:27:47 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.credential: is not defined in the schema and the schema does not allow additional properties, $.part_size_mb: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_path: is not defined in the schema and the schema does not allow additional properties, $.keep_files_in_gcs-bucket: is not defined in the schema and the schema does not allow additional properties, $.method: must be a constant value Standard 2022-07-06 17:27:47 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.part_size_mb: is not defined in the schema and the schema does not allow additional properties