chore: per review

GreptimeTeam · May 15, 2024 · b4708c2 · b4708c2
1 parent a9f16e8
commit b4708c2
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs
@@ -28,5 +28,5 @@ mod worker;
 pub const PER_REQ_MAX_ROW_CNT: usize = 8192;
 // TODO: refactor common types for flow to a separate module
 /// FlowId is a unique identifier for a flow task
-pub type FlowId = u64;
+pub type FlowId = u32;
 pub type TableName = [String; 3];
diff --git a/src/flow/src/adapter/table_source.rs b/src/flow/src/adapter/table_source.rs
@@ -89,7 +89,7 @@ impl TableSource {
             .map(|name| [name.catalog_name, name.schema_name, name.table_name])
     }
 
-    /// query metasrv about the table name and table id
+    /// query metasrv about the `TableInfoValue` and table id
     pub async fn get_table_info_value(
         &self,
         table_id: &TableId,

diff --git a/src/flow/src/adapter/util.rs b/src/flow/src/adapter/util.rs
@@ -32,7 +32,7 @@ pub fn column_schemas_to_proto(
             ColumnDataTypeWrapper::try_from(c.data_type.clone())
                 .map(|w| w.to_parts())
                 .map_err(BoxedError::new)
-                .with_context(|_| ExternalSnafu)
+                .context(ExternalSnafu)
         })
         .try_collect()?;