From bbdc2276be08eb0a9d7eef01232c775f809ae5f0 Mon Sep 17 00:00:00 2001 From: Jinser Kafka Date: Thu, 27 Jun 2024 14:03:01 +0800 Subject: [PATCH] fix: mysteriously no stage code --- src/connector/src/sink/big_query.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/connector/src/sink/big_query.rs b/src/connector/src/sink/big_query.rs index af8967bb95ca2..df800f234831c 100644 --- a/src/connector/src/sink/big_query.rs +++ b/src/connector/src/sink/big_query.rs @@ -89,6 +89,7 @@ pub struct BigQueryCommon { #[serde_as(as = "DisplayFromStr")] pub retry_times: usize, #[serde(default)] // default false + #[serde_as(as = "DisplayFromStr")] pub auto_create: bool, } @@ -377,7 +378,7 @@ impl Sink for BigQuerySink { .get(project_id, dataset_id, table_id, None) .await { - Err(BQError::ResponseError { error: _ }) => { + Err(BQError::RequestError(_)) => { // early return: no need to query schema to check column and type return self .create_table(