From a833f96a2cffc9a84296eb19a589de80d5e15462 Mon Sep 17 00:00:00 2001 From: tabVersion Date: Tue, 10 Sep 2024 15:15:17 +0800 Subject: [PATCH] fix Signed-off-by: tabVersion --- src/connector/src/parser/unified/kv_event.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/connector/src/parser/unified/kv_event.rs b/src/connector/src/parser/unified/kv_event.rs index cad70bc23429..3f3e1312f812 100644 --- a/src/connector/src/parser/unified/kv_event.rs +++ b/src/connector/src/parser/unified/kv_event.rs @@ -81,7 +81,7 @@ where Some(AdditionalColumnType::Key(_)) => self.access_key(&[&desc.name], &desc.data_type), // hack here: Get the whole payload as a single column // use a special mark "." as column name to represent the whole payload - Some(AdditionalColumnType::Payload(_)) => self.access_value(&[&"."], &desc.data_type), + Some(AdditionalColumnType::Payload(_)) => self.access_value(&["."], &desc.data_type), None => self.access_value(&[&desc.name], &desc.data_type), _ => unreachable!(), }