From 5f09a750bbb3592b810ac6b92ba08d065105f2ef Mon Sep 17 00:00:00 2001 From: StrikeW Date: Wed, 5 Jun 2024 16:36:57 +0800 Subject: [PATCH] fix --- src/connector/src/parser/unified/debezium.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/connector/src/parser/unified/debezium.rs b/src/connector/src/parser/unified/debezium.rs index f2af44a2e4310..a353a39369c32 100644 --- a/src/connector/src/parser/unified/debezium.rs +++ b/src/connector/src/parser/unified/debezium.rs @@ -212,22 +212,22 @@ where .value_accessor .as_ref() .expect("value_accessor must be provided for upsert operation") - .access(&[SOURCE, SOURCE_DB], Some(&desc.data_type)), + .access(&[SOURCE, SOURCE_DB], &desc.data_type), ColumnType::SchemaName(_) => self .value_accessor .as_ref() .expect("value_accessor must be provided for upsert operation") - .access(&[SOURCE, SOURCE_SCHEMA], Some(&desc.data_type)), + .access(&[SOURCE, SOURCE_SCHEMA], &desc.data_type), ColumnType::TableName(_) => self .value_accessor .as_ref() .expect("value_accessor must be provided for upsert operation") - .access(&[SOURCE, SOURCE_TABLE], Some(&desc.data_type)), + .access(&[SOURCE, SOURCE_TABLE], &desc.data_type), ColumnType::CollectionName(_) => self .value_accessor .as_ref() .expect("value_accessor must be provided for upsert operation") - .access(&[SOURCE, SOURCE_COLLECTION], Some(&desc.data_type)), + .access(&[SOURCE, SOURCE_COLLECTION], &desc.data_type), _ => Err(AccessError::UnsupportedAdditionalColumn { name: desc.name.clone(), }),