Justas Černas
08/25/2023, 11:34 AM500 Internal Server Error
And the logs from the airbyte-api-server
ERROR i.m.h.s.RouteExecutor(logException):444 - Unexpected error occurred: null
java.lang.NullPointerException: null
at io.airbyte.api.server.helpers.AirbyteCatalogHelper.hasStreamConfigurations(AirbyteCatalogHelper.kt:51) ~[io.airbyte-airbyte-api-server-0.50.21.jar:?]
at io.airbyte.api.server.controllers.ConnectionsController.createConnection(ConnectionsController.kt:81) ~[io.airbyte-airbyte-api-server-0.50.21.jar:?]
at io.airbyte.api.server.controllers.$ConnectionsController$Definition$Exec.dispatch(Unknown Source) ~[io.airbyte-airbyte-api-server-0.50.21.jar:?]
at io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:371) ~[micronaut-inject-3.9.4.jar:3.9.4]
at io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:594) ~[micronaut-inject-3.9.4.jar:3.9.4]
at io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303) ~[micronaut-router-3.9.4.jar:3.9.4]
at io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111) ~[micronaut-router-3.9.4.jar:3.9.4]
at io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103) ~[micronaut-http-3.9.4.jar:3.9.4]
at io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:659) ~[micronaut-http-server-3.9.4.jar:3.9.4]
at reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49) ~[reactor-core-3.5.5.jar:3.5.5]
at reactor.core.publisher.Flux.subscribe(Flux.java:8671) ~[reactor-core-3.5.5.jar:3.5.5]
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:427) ~[reactor-core-3.5.5.jar:3.5.5]
at io.micronaut.reactive.reactor.instrument.ReactorSubscriber.onNext(ReactorSubscriber.java:57) ~[micronaut-runtime-3.9.4.jar:3.9.4]
at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:172) ~[reactor-core-3.5.5.jar:3.5.5]
at io.micronaut.http.server.netty.RoutingInBoundHandler$4.doOnComplete(RoutingInBoundHandler.java:965) ~[micronaut-http-server-netty-3.9.4.jar:3.9.4]
at io.micronaut.core.async.subscriber.CompletionAwareSubscriber.onComplete(CompletionAwareSubscriber.java:79) ~[micronaut-core-reactive-3.9.4.jar:3.9.4]
at io.micronaut.http.server.netty.jackson.JsonContentProcessor$1.doOnComplete(JsonContentProcessor.java:136) ~[micronaut-http-server-netty-3.9.4.jar:3.9.4]
at io.micronaut.core.async.subscriber.CompletionAwareSubscriber.onComplete(CompletionAwareSubscriber.java:79) ~[micronaut-core-reactive-3.9.4.jar:3.9.4]
at java.util.Optional.ifPresent(Optional.java:178) ~[?:?]
at io.micronaut.core.async.processor.SingleThreadedBufferingProcessor.doOnComplete(SingleThreadedBufferingProcessor.java:48) ~[micronaut-core-reactive-3.9.4.jar:3.9.4]
at io.micronaut.jackson.core.parser.JacksonCoreProcessor.doOnComplete(JacksonCoreProcessor.java:94) ~[micronaut-jackson-core-3.9.4.jar:3.9.4]
at io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber.onComplete(SingleThreadedBufferingSubscriber.java:71) ~[micronaut-core-reactive-3.9.4.jar:3.9.4]
at io.micronaut.http.server.netty.jackson.JsonContentProcessor.doOnComplete(JsonContentProcessor.java:161) ~[micronaut-http-server-netty-3.9.4.jar:3.9.4]
at io.micronaut.core.async.subscriber.CompletionAwareSubscriber.onComplete(CompletionAwareSubscriber.java:79) ~[micronaut-core-reactive-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher.publishMessage(HandlerPublisher.java:383) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher.flushBuffer(HandlerPublisher.java:470) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher.publishMessageLater(HandlerPublisher.java:360) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher.complete(HandlerPublisher.java:423) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher.handlerRemoved(HandlerPublisher.java:418) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.netty.channel.AbstractChannelHandlerContext.callHandlerRemoved(AbstractChannelHandlerContext.java:1122) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.DefaultChannelPipeline.callHandlerRemoved0(DefaultChannelPipeline.java:637) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.DefaultChannelPipeline.remove(DefaultChannelPipeline.java:477) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.DefaultChannelPipeline.remove(DefaultChannelPipeline.java:423) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.micronaut.http.netty.stream.HttpStreamsHandler.removeHandlerIfActive(HttpStreamsHandler.java:512) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.stream.HttpStreamsHandler.handleReadHttpContent(HttpStreamsHandler.java:320) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.stream.HttpStreamsHandler.channelRead(HttpStreamsHandler.java:283) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.stream.HttpStreamsServerHandler.channelRead(HttpStreamsServerHandler.java:134) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.codec.http.websocketx.extensions.WebSocketServerExtensionHandler.channelRead(WebSocketServerExtensionHandler.java:88) ~[netty-codec-http-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) ~[netty-codec-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) ~[netty-codec-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.codec.MessageToMessageCodec.channelRead(MessageToMessageCodec.java:111) ~[netty-codec-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.codec.http.HttpServerKeepAliveHandler.channelRead(HttpServerKeepAliveHandler.java:64) ~[netty-codec-http-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.flow.FlowControlHandler.dequeue(FlowControlHandler.java:202) ~[netty-handler-4.1.94.Final.jar:4.1.94.Final]
at io.netty.handler.flow.FlowControlHandler.read(FlowControlHandler.java:139) ~[netty-handler-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeRead(AbstractChannelHandlerContext.java:837) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.AbstractChannelHandlerContext.read(AbstractChannelHandlerContext.java:814) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.micronaut.http.netty.reactive.HandlerPublisher.requestDemand(HandlerPublisher.java:165) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.stream.HttpStreamsHandler$2.requestDemand(HttpStreamsHandler.java:274) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.receivedDemand(HandlerPublisher.java:556) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.lambda$request$0(HandlerPublisher.java:494) ~[micronaut-http-netty-3.9.4.jar:3.9.4]
at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566) ~[netty-transport-4.1.94.Final.jar:4.1.94.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.94.Final.jar:4.1.94.Final]
at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Any directions on this, what might be causing it?Sunil Jimenez
08/25/2023, 1:14 PMEduardo Trevisani
08/28/2023, 9:16 PMsource_zendesk_support_authentication_api_token
nested field of the credentials field (available in the docs).
When applying a Terraform code that uses it, the API gets an unexpected response code 422, with the details that read:
{"type":"<https://reference.airbyte.com/reference/errors#unprocessable-entity>","status":422,"title":"unprocessable-entity","detail":"The provided
configuration does not fulfill the specification. Errors: json schema validation failed when comparing the data to the json schema. \nErrors: $.credentials:
null found, object expected, $.credentials: null found, object expected "}
Looks like that the parser sets the credentials field to null
when I’m using this field, as shown in the API payload that generated the above response:
{
"configuration": {
"credentials": null,
"ignore_pagination": true,
"sourceType": "zendesk-support",
"start_date": "2023-01-01T00:00:00Z",
"subdomain": "[REDACTED]"
},
"name": "airbyte.zendesk-support",
"workspaceId": "[REDACTED]"
}
When using a different field like source_zendesk_support_update_authentication_api_token
(available it this doc), the error does not occur. Even though, while the source is created, the credentials are not, resulting in a source created without any Authentication fields, as seen in the print-screen attached.
The Terraform code I’m using is
resource "airbyte_source_zendesk_support" "source_zendesk_support" {
name = "airbyte.zendesk-support"
workspace_id = var.workspace_id
configuration = {
source_type = "zendesk-support"
subdomain = var.zendesk["subdomain"]
start_date = "2023-01-01T00:00:00Z"
ignore_pagination = true
credentials = {
source_zendesk_support_authentication_api_token = {
credentials = "api_token"
api_token = var.zendesk["api_token"]
email = var.zendesk["email"]
}
}
}
}
Frank Mena
08/31/2023, 5:09 PMFrank Mena
08/31/2023, 5:09 PMFrank Mena
08/31/2023, 5:09 PMGaëtan Podevijn
09/01/2023, 8:45 AMThibaut B
09/04/2023, 10:40 AMChristos Gkournelos
09/05/2023, 5:38 PMSteven Schmatz
09/05/2023, 7:03 PMuser
09/05/2023, 9:38 PMpython sync_airbyte_connection = AirbyteConnectionTask( max_retries=3, retry_delay=timedelta(seconds=10) ) # Sync Airbyte GitHub data airbyte_github_sync = sync_airbyte_connection( airbyte_server_host="localhost", airbyte_server_port=8000, airbyte_api_version="v1", connection_id=airbyte_github_connection_id, ) # Sync dbt GitHub data dbt_github_sync = sync_airbyte_connection( connection_id=dbt_github_connection_id, airbyte_server_host="localhost", airbyte_server_port=8000, airbyte_api_version="v1", ) # Sync Prefect GitHub data prefect_github_sync = sync_airbyte_connection( airbyte_server_host="localhost", airbyte_server_port=8000, airbyte_api_version="v1", connection_id=prefect_github_connection_id, )
You can find more information about this in the [Prefect Airbyte Task documentation](https://docs.prefect.io/api/latest/tasks/airbyte.html#airbyteconnectiontask) and the [Airbyte documentation](https://docs.airbyte.com/operator-guides/using-prefect-task). However, please note that the examples provided are for a local instance of Airbyte. If you're using Airbyte Cloud, you'll need to replace "localhost" and "8000" with the appropriate host and port for your Airbyte Cloud instance.Brandon Freeman
09/06/2023, 12:47 PM404
when hitting the localhost:8006/v1/jobs/{job_id}
endpoint for valid `job_id`s in my v0.50.14
OSS implementation.
Seems that others are experiencing the same with v0.50.24
.
Hitting /v1/jobs?status=running
I'll get the expected output:
{'data': [
{
'connectionId': 'aaeb5f07-76dc-4b0a-9498-40f26c4cdfe4',
'duration': 'PT0S',
'jobId': 4442,
'jobType': 'sync',
'startTime': '2023-09-05T22:15:43Z',
'status': 'running'
},
{
'connectionId': '52342a79-b9f7-4258-ad53-d067d0340c6e',
'duration': 'PT0S',
'jobId': 4439,
'jobType': 'sync',
'startTime': '2023-09-05T16:08:52Z',
'status': 'running'
}
]}
Yet when I make the call to /v1/jobs/4442
or /v1/jobs/4439
I simply get a 404 - Not Found
response.Chris Eik
09/07/2023, 4:20 PMData Staging Method
via terraform.
Manually selecting both and putting in a password works fine.
terraform 0.3.3 and airbyte 0.50.27Carolina Buckler
09/08/2023, 6:06 PMVeeraswamy G
09/08/2023, 7:54 PMJason Maddern
09/11/2023, 2:13 AMERROR i.a.w.i.EmptyAirbyteSource(start):101 - The state a legacy one but we are trying to do a partial update, this is not supported.
Source: Oracle 0.4.0 (latest)
Destination: Snowflake 3.1.2 (latest)
Airbyte: 0.50.5 (which agreed needs an upgrade)
Any ideas on which component specifically isn't supporting this and I can upgrade/change?Steven Murphy
09/11/2023, 2:40 PMNguyen Dao (Bach)
09/11/2023, 5:58 PMVignesh Sivarajah
09/12/2023, 10:35 AMLouis Auneau
09/13/2023, 7:44 PMairbyte_source_postgres
and airbyte_source_zendesk_support
with provider in v0.3.4. I have some attributes that are ignored and sent as null
to the API, resulting in a fail during the terraform apply. Here are my two sources:
resource "airbyte_source_zendesk_support" "******_zendesk_support" {
name = "Zendesk Support"
workspace_id = var.workspace_id
configuration = {
credentials = {
source_zendesk_support_authentication_api_token = {
email = "******"
api_token = var.zendesk_api_token
credentials = "api_token"
}
}
ignore_pagination = false
source_type = "zendesk-support"
start_date = "2023-05-01T00:00:00Z"
subdomain = "******"
}
}
resource "airbyte_source_postgres" "******_postgres" {
workspace_id = var.workspace_id
name = "CloudSQL Production"
configuration = {
host = var.database_hostname
port = 5432
database = "******"
username = var.database_username
password = var.database_password
source_type = "postgres"
replication_method = {
source_postgres_update_method_read_changes_using_write_ahead_log_cdc = {
method = "CDC"
publication = "******"
replication_slot = "******"
}
}
schemas = [******]
}
}
When running the terraform apply, the airbyte_source_zendesk_support.configuration.credentials
and airbyte_source_postgres.configuration.replication_method
are set as null.
Do you have any idea why this happens to these specific blocks. They both seem to respect the schema.
Thank you by advance!
LouisVignesh Sivarajah
09/18/2023, 7:16 AMsource|destination|connection
with code. The official docs are pointing to <http://api.airbyte.com|api.airbyte.com>
: https://reference.airbyte.com/reference/createsource.Amit Jaiswal
09/19/2023, 8:52 PMWebhook test failed. Please verify that the webhook URL is valid
When I hit the notification API using the following params:
curl --location --request POST '<http://localhost:80002/api/v1/notifications/try>' \
--header 'Authorization: Basic ' \
--header 'Content-Type: application/json' \
--data-raw '{
"notificationType": "slack",
"sendOnSuccess": true,
"sendOnFailure": true,
"slackConfiguration": {
"webhook": "<https://hooks.slack.com/services/><EXTRA_CHARS>"
},
"customerioConfiguration": {}
}'
Getting an empty response with 200 status?
I see server logs and I see nothing there. Is there a way to fix this.Rutul Saraiya
09/21/2023, 5:24 AMAuthorization:Basic xxxxxxxxxxxxxxx
accept:application/json
content-type:application/json
{
"configuration": {
"sourceType": "mysql",
"port": 3306,
"ssl_mode": {
"mode": "preferred"
},
"replication_method": {
"method": "STANDARD"
},
"tunnel_method": {
"tunnel_method": "NO_TUNNEL"
},
"host": "xx.xx.xx.xx",
"database": "sourcedb",
"username": "root",
"password": "xxxxx"
},
"name": "servermysql",
"workspaceId": "544cc0ed-7f05-4949-9e60-2a814f90c035"
}
I always get following response
{
"type": "<https://reference.airbyte.com/reference/errors>",
"title": "unexpected-problem",
"status": 500,
"detail": "An unexpected problem has occurred. If this is an error that needs to be addressed, please submit a pull request or github issue."
}
Can anyone suggest in this issue ?Shubham
09/21/2023, 7:35 AMAirbyteTriggerSyncOperator
to trigger sync of my airbyte jobs using airfow.
I want to trigger these tasks inside a dag conditionally.
I.e. if a condition is false then I want to skip this task which triggers a sync job and move on with the rest of the DAG
How do I do it?Cyprien Barbault
09/21/2023, 9:50 AMCyprien Barbault
09/21/2023, 12:59 PMcontext deadline exceeded (Client.Timeout exceeded while awaiting headers)
Nguyen Dao (Bach)
09/25/2023, 11:15 PMTim Clemans
09/25/2023, 11:36 PMdata: 'stream timeout'
or data: 'upstream request timeout'
I believe the create connection api call is failing.
AirByte OSS version: 0.50.30
Postgres Source version: 3.1.8
BigQuery Destination version: 2.0.16
Any ideas?KENNEDY SITATI
09/26/2023, 7:43 AMAnil Kumar
09/27/2023, 9:26 AM