diff --git a/src/sst-convert/src/reader/remote_write.rs b/src/sst-convert/src/reader/remote_write.rs index 3f3260a440..c0766953b1 100644 --- a/src/sst-convert/src/reader/remote_write.rs +++ b/src/sst-convert/src/reader/remote_write.rs @@ -320,10 +320,10 @@ impl PrimaryKeyEncoder { None => { let table_info = self .table_helper - .get_table(&self.catalog, &self.schema, &name_label.name) + .get_table(&self.catalog, &self.schema, &name_label.value) .await? .context(MissingTableSnafu { - table_name: &name_label.name, + table_name: &name_label.value, })?; let id = table_info.table_info.ident.table_id; self.table_ids.insert(name_label.name.clone(), id);