From caff755010e8d38d400ba918fb38e15970ae6fb2 Mon Sep 17 00:00:00 2001 From: xxhZs <1060434431@qq.com> Date: Sun, 29 Sep 2024 13:43:57 +0800 Subject: [PATCH] fix --- src/connector/src/sink/big_query.rs | 11 ++++++----- src/connector/src/sink/google_pubsub.rs | 8 +++----- 2 files changed, 9 insertions(+), 10 deletions(-) diff --git a/src/connector/src/sink/big_query.rs b/src/connector/src/sink/big_query.rs index 85e8ba0187c9..6e231f7542db 100644 --- a/src/connector/src/sink/big_query.rs +++ b/src/connector/src/sink/big_query.rs @@ -819,11 +819,12 @@ impl StorageWriterClient { } fn bigquery_grpc_auth_config() -> google_cloud_auth::project::Config<'static> { - google_cloud_auth::project::Config { - audience: Some(google_cloud_bigquery::grpc::apiv1::conn_pool::AUDIENCE), - scopes: Some(&google_cloud_bigquery::grpc::apiv1::conn_pool::SCOPES), - sub: None, - } + let mut auth_config = google_cloud_auth::project::Config::default(); + auth_config = + auth_config.with_audience(google_cloud_bigquery::grpc::apiv1::conn_pool::AUDIENCE); + auth_config = + auth_config.with_scopes(&google_cloud_bigquery::grpc::apiv1::conn_pool::SCOPES); + auth_config } } diff --git a/src/connector/src/sink/google_pubsub.rs b/src/connector/src/sink/google_pubsub.rs index ff9079591a2f..e84c626f16a5 100644 --- a/src/connector/src/sink/google_pubsub.rs +++ b/src/connector/src/sink/google_pubsub.rs @@ -192,11 +192,9 @@ impl GooglePubSubSinkWriter { sink_from_name: String, ) -> Result { let environment = if let Some(ref cred) = config.credentials { - let auth_config = project::Config { - audience: Some(apiv1::conn_pool::AUDIENCE), - scopes: Some(&apiv1::conn_pool::SCOPES), - sub: None, - }; + let mut auth_config = project::Config::default(); + auth_config = auth_config.with_audience(apiv1::conn_pool::AUDIENCE); + auth_config = auth_config.with_scopes(&apiv1::conn_pool::SCOPES); let cred_file = CredentialsFile::new_from_str(cred).await.map_err(|e| { SinkError::GooglePubSub( anyhow!(e).context("Failed to create Google Cloud Pub/Sub credentials file"),