diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs
index 053ad3adaba8..33b05ddec12b 100644
--- 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
index a153b19ac8e7..cfa41f785ac8 100644
--- 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
index 235917ac8724..1946d4265d3f 100644
--- 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()?;