fix size

src/connector/src/sink/big_query.rs

@@ -28,7 +28,6 @@ use risingwave_common::catalog::Schema;
 use risingwave_common::types::DataType;
 use serde_derive::Deserialize;
 use serde_json::Value;
-use serde_with::serde_as;
 use url::Url;
 use with_options::WithOptions;
 use yup_oauth2::ServiceAccountKey;
@@ -39,12 +38,14 @@ use super::{SinkError, SINK_TYPE_APPEND_ONLY, SINK_TYPE_OPTION, SINK_TYPE_UPSERT
 use crate::aws_utils::load_file_descriptor_from_s3;
 use crate::common::AwsAuthProps;
 use crate::sink::writer::SinkWriterExt;
+use serde_with::{serde_as, DisplayFromStr};
 use crate::sink::{
     DummySinkCommitCoordinator, Result, Sink, SinkParam, SinkWriter, SinkWriterParam,
 };
 
 pub const BIGQUERY_SINK: &str = "bigquery";
 
+#[serde_as]
 #[derive(Deserialize, Debug, Clone, WithOptions)]
 pub struct BigQueryCommon {
     #[serde(rename = "bigquery.local.path")]
@@ -58,6 +59,7 @@ pub struct BigQueryCommon {
     #[serde(rename = "bigquery.table")]
     pub table: String,
     #[serde(rename = "bigquery.max_batch_rows", default = "default_max_batch_rows")]
+    #[serde_as(as = "DisplayFromStr")]
     pub max_batch_rows: usize,
 }