2022-05-25 14:35:58 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.11-alpha
2022-05-25 14:35:58 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/118/0/logs.log
2022-05-25 14:35:58 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.36.11-alpha
2022-05-25 14:35:58 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 118 attempt id: 0
2022-05-25 14:35:58 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.events=full_refresh - append}
2022-05-25 14:35:58 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-25 14:35:59 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery-denormalized:1.1.6 exists...
2022-05-25 14:35:59 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery-denormalized:1.1.6 was found locally.
2022-05-25 14:35:59 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 118
2022-05-25 14:35:59 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/118/0 --log-driver none --name destination-bigquery-denormalized-write-118-0-vudln --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery-denormalized:1.1.6 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.11-alpha -e WORKER_JOB_ID=118 airbyte/destination-bigquery-denormalized:1.1.6 write --config destination_config.json --catalog destination_catalog.json
2022-05-25 14:35:59 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-timely:2.0 exists...
2022-05-25 14:35:59 destination > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2022-05-25 14:35:59 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-timely:2.0 was found locally.
2022-05-25 14:35:59 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 118
2022-05-25 14:35:59 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/118/0 --log-driver none --name source-timely-read-118-0-tbflg --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-timely:2.0 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.11-alpha -e WORKER_JOB_ID=118 airbyte/source-timely:2.0 read --config source_config.json --catalog source_catalog.json
2022-05-25 14:36:00 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-05-25 14:36:00 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-05-25 14:36:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-05-25 14:36:01 source > Starting syncing SourceTimelyIntegration
2022-05-25 14:36:01 source > Syncing stream: events 
2022-05-25 14:36:02 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-05-25 14:36:02 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-25 14:36:02 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-25 14:36:02 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-25 14:36:02 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-05-25 14:36:02 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-05-25 14:36:05 destination > 2022-05-25 14:36:05 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-25 14:36:05 destination > 2022-05-25 14:36:05 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination
2022-05-25 14:36:05 destination > 2022-05-25 14:36:05 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-05-25 14:36:05 destination > 2022-05-25 14:36:05 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-05-25 14:36:06 destination > 2022-05-25 14:36:06 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-05-25 14:36:06 destination > 2022-05-25 14:36:06 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-05-25 14:36:06 destination > 2022-05-25 14:36:06 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):303 - Selected loading method is set to: GCS
2022-05-25 14:36:07 destination > 2022-05-25 14:36:07 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"AVRO","flattening":"No flattening","part_size_mb":"5"}
2022-05-25 14:36:07 destination > 2022-05-25 14:36:07 INFO i.a.i.d.b.BigQueryUtils(isKeepFilesInGcs):319 - All tmp files will be removed from GCS when replication is finished
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.BigQueryDestination(getGcsRecordConsumer):286 - Creating BigQuery staging message consumer with staging ID 541271fb-b4ec-4690-81d6-847a42d22a1b at 2022-05-25T14:36:07.405Z
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(formatAllOfAndAnyOfFields):68 - getSchemaFields : {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"date-time"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["null","array"]},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["null","array"]}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["null","array"]},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["null","array"]},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@1c6c6f24
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getSchemaFields):222 - getSchemaFields : {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"timestamp-micros"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@1c6c6f24
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getBigQuerySchema):217 - Airbyte Schema is transformed from {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"timestamp-micros"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} to [Field{name=id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=to, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=day, type=TIMESTAMP, mode=NULLABLE, description=null, policyTags=null}, Field{name=uid, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=note, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=user, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=draft, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=billed, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=manage, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=deleted, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=project, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billable, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=sequence, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=user_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billed_at, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=entry_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=estimated, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=hour_rate, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=label_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=created_at, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=invoice_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updater_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=external_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=forecast_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_state, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updated_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked_reason, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=suggestion_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=timer_started_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_stopped_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=hour_rate_in_cents, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}].
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=events, namespace=poke_api, datasetId=poke_api, datasetLocation=US, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=poke_api, tableId=_airbyte_tmp_swa_events}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=poke_api, tableId=events}}, tableSchema=Schema{fields=[Field{name=id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=to, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=day, type=TIMESTAMP, mode=NULLABLE, description=null, policyTags=null}, Field{name=uid, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=note, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=user, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=draft, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=billed, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=manage, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=deleted, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=project, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billable, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=sequence, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=user_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billed_at, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=entry_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=estimated, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=hour_rate, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=label_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=created_at, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=invoice_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updater_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=external_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=forecast_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_state, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updated_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked_reason, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=suggestion_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=timer_started_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_stopped_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=hour_rate_in_cents, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}]}, syncMode=append, stagedFiles=[]]
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):98 - Preparing tmp tables in destination started for 1 streams
2022-05-25 14:36:10 destination > 2022-05-25 14:36:10 INFO i.a.i.d.b.BigQueryGcsOperations(createSchemaIfNotExists):86 - Creating dataset poke_api
2022-05-25 14:36:13 destination > 2022-05-25 14:36:13 INFO i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=poke_api, tableId=_airbyte_tmp_swa_events}}
2022-05-25 14:36:14 destination > 2022-05-25 14:36:14 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=poke_api, tableId=_airbyte_tmp_swa_events}}
2022-05-25 14:36:14 destination > 2022-05-25 14:36:14 INFO i.a.i.d.b.BigQueryGcsOperations(createStageIfNotExists):101 - Creating staging path for stream events (dataset poke_api): airbyte/events/poke_api_events/2022/05/25/14/541271fb-b4ec-4690-81d6-847a42d22a1b/
2022-05-25 14:36:15 destination > 2022-05-25 14:36:15 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):97 - Storage Object py3r87c9czm5-us-airbyte/airbyte/events/poke_api_events/2022/05/25/14/541271fb-b4ec-4690-81d6-847a42d22a1b/ does not exist in bucket; creating...
2022-05-25 14:36:16 destination > 2022-05-25 14:36:16 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):99 - Storage Object py3r87c9czm5-us-airbyte/airbyte/events/poke_api_events/2022/05/25/14/541271fb-b4ec-4690-81d6-847a42d22a1b/ has been created in bucket.
2022-05-25 14:36:16 destination > 2022-05-25 14:36:16 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):107 - Preparing tmp tables in destination completed.
2022-05-25 14:36:30 destination > 2022-05-25 14:36:30 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream events (current state: 0 bytes in 0 buffers)
2022-05-25 14:36:30 destination > 2022-05-25 14:36:30 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(formatAllOfAndAnyOfFields):68 - getSchemaFields : {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"date-time"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["null","array"]},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["null","array"]}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["null","array"]},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["null","array"]},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@1c6c6f24
2022-05-25 14:36:30 destination > 2022-05-25 14:36:30 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getSchemaFields):222 - getSchemaFields : {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"timestamp-micros"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} namingResolver io.airbyte.integrations.destination.bigquery.BigQuerySQLNameTransformer@1c6c6f24
2022-05-25 14:36:30 destination > 2022-05-25 14:36:30 INFO i.a.i.d.b.f.DefaultBigQueryDenormalizedRecordFormatter(getBigQuerySchema):217 - Airbyte Schema is transformed from {"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"timestamp-micros"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["object"],"properties":{"big_query_array":{"type":["null","array"],"items":{"type":["string"]}}}},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}} to [Field{name=id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=to, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=day, type=TIMESTAMP, mode=NULLABLE, description=null, policyTags=null}, Field{name=uid, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=note, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=user, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=draft, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=billed, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=manage, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=deleted, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=project, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billable, type=BOOLEAN, mode=NULLABLE, description=null, policyTags=null}, Field{name=duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=sequence, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=user_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=billed_at, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=entry_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=estimated, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=hour_rate, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=label_ids, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=created_at, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=invoice_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updater_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=external_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=forecast_id, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_state, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=created_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=updated_from, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=locked_reason, type=STRING, mode=NULLABLE, description=null, policyTags=null}, Field{name=suggestion_id, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_cost, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=timer_started_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=timer_stopped_on, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=estimated_duration, type=RECORD, mode=null, description=null, policyTags=null}, Field{name=hour_rate_in_cents, type=INTEGER, mode=NULLABLE, description=null, policyTags=null}, Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}].
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 ERROR i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):52 - Exception while accepting message
2022-05-25 14:36:31 destination > tech.allegro.schema.json2avro.converter.AvroConversionException: Failed to convert JSON to Avro: Could not evaluate union, field project is expected to be one of these: NULL, RECORD. If this is a complex type, check if offending field (path: project.hour_rate) adheres to schema: {required_notes=false, color=47b17c, external_id=ABTA, budget_expired_on=null, budget_percent=0.0, rate_type=project, budget_scope=null, updated_at=1653488857, budget_progress=0.0, client={updated_at=2022-05-24T09:27:22-07:00, name=Abata Therapeutics, active=true, external_id=ABTA, id=1555597}, id=3645496, budget_calculation=completed, hour_rate_in_cents=18000.0, has_recurrence=false, budget_type=, budget=0, required_label_ids={big_query_array=[]}, invoice_by_budget=false, label_ids={big_query_array=[]}, active=true, required_labels=false, billable=true, labels={big_query_array=[]}, account_id=858950, name=ABTA - General Support, enable_labels=none, hour_rate=180.0}
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:129) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:118) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonAvroConverter.convertToGenericDataRecord(JsonAvroConverter.java:95) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.s3.avro.AvroRecordFactory.getAvroRecord(AvroRecordFactory.java:44) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.bigquery.BigQueryAvroSerializedBuffer.writeRecord(BigQueryAvroSerializedBuffer.java:46) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.record_buffer.BaseSerializedBuffer.accept(BaseSerializedBuffer.java:92) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:69) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:194) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$4(IntegrationRunner.java:203) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:232) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:202) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:165) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:165) [io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) [io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > 	at io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination.main(BigQueryDenormalizedDestination.java:72) [io.airbyte.airbyte-integrations.connectors-destination-bigquery-denormalized-0.38.3-alpha.jar:?]
2022-05-25 14:36:31 destination > Caused by: org.apache.avro.AvroTypeException: Could not evaluate union, field project is expected to be one of these: NULL, RECORD. If this is a complex type, check if offending field (path: project.hour_rate) adheres to schema: {required_notes=false, color=47b17c, external_id=ABTA, budget_expired_on=null, budget_percent=0.0, rate_type=project, budget_scope=null, updated_at=1653488857, budget_progress=0.0, client={updated_at=2022-05-24T09:27:22-07:00, name=Abata Therapeutics, active=true, external_id=ABTA, id=1555597}, id=3645496, budget_calculation=completed, hour_rate_in_cents=18000.0, has_recurrence=false, budget_type=, budget=0, required_label_ids={big_query_array=[]}, invoice_by_budget=false, label_ids={big_query_array=[]}, active=true, required_labels=false, billable=true, labels={big_query_array=[]}, account_id=858950, name=ABTA - General Support, enable_labels=none, hour_rate=180.0}
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.AvroTypeExceptions.unionException(AvroTypeExceptions.java:28) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readUnion(JsonGenericRecordReader.java:294) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:196) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:170) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.lambda$readRecord$0(JsonGenericRecordReader.java:152) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at java.util.LinkedHashMap.forEach(LinkedHashMap.java:721) ~[?:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readRecord(JsonGenericRecordReader.java:141) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:127) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:31 destination > 	... 18 more
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 WARN i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: failed.
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 ERROR i.a.i.d.b.BufferedStreamConsumer(close):168 - executing on failed close procedure.
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream events
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data f04a9e4d-6d88-42ce-8aa7-867c471fd9fa2683502000852414584.avro
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):159 - Cleaning up destination started for 1 streams
2022-05-25 14:36:31 destination > 2022-05-25 14:36:31 INFO i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=poke_api, tableId=_airbyte_tmp_swa_events}} (dataset poke_api)
2022-05-25 14:36:32 destination > 2022-05-25 14:36:32 INFO i.a.i.d.b.BigQueryGcsOperations(dropStageIfExists):183 - Cleaning up staging path for stream events (dataset poke_api): airbyte/events/poke_api_events
2022-05-25 14:36:32 destination > 2022-05-25 14:36:32 INFO i.a.i.d.g.GcsStorageOperations(cleanUpObjects):43 - Deleting object airbyte/events/poke_api_events/2022/05/25/14/541271fb-b4ec-4690-81d6-847a42d22a1b/
2022-05-25 14:36:32 destination > 2022-05-25 14:36:32 INFO i.a.i.d.s.S3StorageOperations(cleanUpBucketObject):268 - Storage bucket airbyte/events/poke_api_events has been cleaned-up (1 objects were deleted)...
2022-05-25 14:36:32 destination > 2022-05-25 14:36:32 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):164 - Cleaning up destination completed.
2022-05-25 14:36:32 destination > 2022-05-25 14:36:32 ERROR i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details.
2022-05-25 14:36:32 destination > tech.allegro.schema.json2avro.converter.AvroConversionException: Failed to convert JSON to Avro: Could not evaluate union, field project is expected to be one of these: NULL, RECORD. If this is a complex type, check if offending field (path: project.hour_rate) adheres to schema: {required_notes=false, color=47b17c, external_id=ABTA, budget_expired_on=null, budget_percent=0.0, rate_type=project, budget_scope=null, updated_at=1653488857, budget_progress=0.0, client={updated_at=2022-05-24T09:27:22-07:00, name=Abata Therapeutics, active=true, external_id=ABTA, id=1555597}, id=3645496, budget_calculation=completed, hour_rate_in_cents=18000.0, has_recurrence=false, budget_type=, budget=0, required_label_ids={big_query_array=[]}, invoice_by_budget=false, label_ids={big_query_array=[]}, active=true, required_labels=false, billable=true, labels={big_query_array=[]}, account_id=858950, name=ABTA - General Support, enable_labels=none, hour_rate=180.0}
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:129) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:118) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonAvroConverter.convertToGenericDataRecord(JsonAvroConverter.java:95) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.s3.avro.AvroRecordFactory.getAvroRecord(AvroRecordFactory.java:44) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.bigquery.BigQueryAvroSerializedBuffer.writeRecord(BigQueryAvroSerializedBuffer.java:46) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.record_buffer.BaseSerializedBuffer.accept(BaseSerializedBuffer.java:92) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:69) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:194) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$4(IntegrationRunner.java:203) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:232) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:202) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:165) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:165) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) ~[io.airbyte.airbyte-integrations.bases-base-java-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > 	at io.airbyte.integrations.destination.bigquery.BigQueryDenormalizedDestination.main(BigQueryDenormalizedDestination.java:72) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-denormalized-0.38.3-alpha.jar:?]
2022-05-25 14:36:32 destination > Caused by: org.apache.avro.AvroTypeException: Could not evaluate union, field project is expected to be one of these: NULL, RECORD. If this is a complex type, check if offending field (path: project.hour_rate) adheres to schema: {required_notes=false, color=47b17c, external_id=ABTA, budget_expired_on=null, budget_percent=0.0, rate_type=project, budget_scope=null, updated_at=1653488857, budget_progress=0.0, client={updated_at=2022-05-24T09:27:22-07:00, name=Abata Therapeutics, active=true, external_id=ABTA, id=1555597}, id=3645496, budget_calculation=completed, hour_rate_in_cents=18000.0, has_recurrence=false, budget_type=, budget=0, required_label_ids={big_query_array=[]}, invoice_by_budget=false, label_ids={big_query_array=[]}, active=true, required_labels=false, billable=true, labels={big_query_array=[]}, account_id=858950, name=ABTA - General Support, enable_labels=none, hour_rate=180.0}
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.AvroTypeExceptions.unionException(AvroTypeExceptions.java:28) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readUnion(JsonGenericRecordReader.java:294) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:196) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:170) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.lambda$readRecord$0(JsonGenericRecordReader.java:152) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at java.util.LinkedHashMap.forEach(LinkedHashMap.java:721) ~[?:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.readRecord(JsonGenericRecordReader.java:141) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	at tech.allegro.schema.json2avro.converter.JsonGenericRecordReader.read(JsonGenericRecordReader.java:127) ~[converter-1.0.1.jar:?]
2022-05-25 14:36:32 destination > 	... 18 more
2022-05-25 14:36:33 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-05-25 14:37:33 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-05-25 14:37:33 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	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:164) ~[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 message delivery failed
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296) ~[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
Caused by: java.io.IOException: Broken pipe
	at java.io.FileOutputStream.writeBytes(Native Method) ~[?:?]
	at java.io.FileOutputStream.write(FileOutputStream.java:349) ~[?:?]
	at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?]
	at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?]
	at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) ~[?:?]
	at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) ~[?:?]
	at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) ~[?:?]
	at java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) ~[?:?]
	at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) ~[?:?]
	at java.io.BufferedWriter.write(BufferedWriter.java:233) ~[?:?]
	at java.io.Writer.write(Writer.java:249) ~[?:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) ~[io.airbyte-airbyte-workers-0.36.11-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294) ~[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-05-25 14:37:33 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@56a9a35b[status=failed,recordsSynced=260,bytesSynced=767443,startTime=1653489358958,endTime=1653489453322,totalStats=io.airbyte.config.SyncStats@34eeedda[recordsEmitted=260,bytesEmitted=767443,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@12bd3941[streamName=events,stats=io.airbyte.config.SyncStats@50e0afd2[recordsEmitted=260,bytesEmitted=767443,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-05-25 14:37:33 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-05-25 14:37:33 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-05-25 14:37:33 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-05-25 14:37:33 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):155 - sync summary: io.airbyte.config.StandardSyncOutput@3f3790b[standardSyncSummary=io.airbyte.config.StandardSyncSummary@468ecf36[status=failed,recordsSynced=260,bytesSynced=767443,startTime=1653489358958,endTime=1653489453322,totalStats=io.airbyte.config.SyncStats@34eeedda[recordsEmitted=260,bytesEmitted=767443,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@12bd3941[streamName=events,stats=io.airbyte.config.SyncStats@50e0afd2[recordsEmitted=260,bytesEmitted=767443,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7b249467[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@179c83a9[stream=io.airbyte.protocol.models.AirbyteStream@fbf8b70[name=events,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"to":{"type":["null","string"]},"day":{"type":["null","string"],"format":"date-time"},"uid":{"type":["null","string"]},"cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"from":{"type":["null","string"]},"note":{"type":["null","string"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"email":{"type":["null","string"]},"avatar":{"type":"object","properties":{"large":{"type":["null","string"]},"medium":{"type":["null","string"]},"timeline":{"type":["null","string"]},"large_retina":{"type":["null","string"]},"medium_retina":{"type":["null","string"]}}},"updated_at":{"type":["null","string"]}}},"draft":{"type":["null","boolean"]},"billed":{"type":["null","boolean"]},"locked":{"type":["null","boolean"]},"manage":{"type":["null","boolean"]},"deleted":{"type":["null","boolean"]},"project":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"color":{"type":["null","string"]},"active":{"type":["null","boolean"]},"budget":{"type":["null","integer"]},"client":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"external_id":{"type":["null","string"]}}},"labels":{"type":["null","array"]},"billable":{"type":["null","boolean"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"rate_type":{"type":["null","string"]},"account_id":{"type":["null","integer"]},"updated_at":{"type":["null","integer"]},"budget_type":{"type":["null","string"]},"external_id":{"type":["null","string"]},"budget_scope":{"type":["null","string"]},"enable_labels":{"type":["null","string"]},"budget_percent":{"type":["null","number"]},"has_recurrence":{"type":["null","boolean"]},"required_notes":{"type":["null","boolean"]},"budget_progress":{"type":["null","number"]},"required_labels":{"type":["null","boolean"]},"budget_expired_on":{"type":["null","string"]},"invoice_by_budget":{"type":["null","boolean"]},"budget_calculation":{"type":["null","string"]},"hour_rate_in_cents":{"type":["null","number"]},"required_label_ids":{"type":["null","array"]}}},"billable":{"type":["null","boolean"]},"duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]},"correctedHours":{"type":["null","integer"]}}},"sequence":{"type":["null","integer"]},"user_ids":{"type":["null","array"]},"billed_at":{"type":["null","string"]},"entry_ids":{"type":["null","array"]},"estimated":{"type":["null","string"]},"hour_rate":{"type":["null","string"]},"label_ids":{"type":["null","array"]},"created_at":{"type":["null","integer"]},"created_id":{"type":["null","integer"]},"invoice_id":{"type":["null","string"]},"updater_id":{"type":["null","integer"]},"external_id":{"type":["null","integer"]},"forecast_id":{"type":["null","string"]},"timer_state":{"type":["null","string"]},"created_from":{"type":["null","string"]},"updated_from":{"type":["null","string"]},"locked_reason":{"type":["null","string"]},"suggestion_id":{"type":["null","integer"]},"estimated_cost":{"type":"object","properties":{"amount":{"type":["null","number"]},"formatted":{"type":["null","string"]},"fractional":{"type":["null","integer"]}}},"timer_started_on":{"type":["null","integer"]},"timer_stopped_on":{"type":["null","integer"]},"estimated_duration":{"type":"object","properties":{"hours":{"type":["null","integer"]},"minutes":{"type":["null","integer"]},"seconds":{"type":["null","integer"]},"formatted":{"type":["null","string"]},"total_hours":{"type":["null","number"]},"total_minutes":{"type":["null","integer"]},"total_seconds":{"type":["null","integer"]}}},"hour_rate_in_cents":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=poke_api,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@3ff812ce[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@60203efa[additionalProperties={attemptNumber=0, jobId=118}],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: Broken pipe
	at java.base/java.io.FileOutputStream.writeBytes(Native Method)
	at java.base/java.io.FileOutputStream.write(FileOutputStream.java:349)
	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=<null>,timestamp=1653489393163]]]
2022-05-25 14:37:33 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-05-25 14:37:33 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