fix(meta): fix type conversion (#18638)

risingwavelabs · Sep 23, 2024 · 9231782 · 9231782
1 parent 8fa0468
commit 9231782
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/src/meta/src/controller/catalog.rs b/src/meta/src/controller/catalog.rs
@@ -2921,16 +2921,23 @@ impl CatalogController {
 
     pub async fn get_all_table_options(&self) -> MetaResult<HashMap<TableId, TableOption>> {
         let inner = self.inner.read().await;
-        let table_options: Vec<(TableId, Option<u32>)> = Table::find()
+        let table_options: Vec<(TableId, Option<i32>)> = Table::find()
             .select_only()
             .columns([table::Column::TableId, table::Column::RetentionSeconds])
-            .into_tuple::<(TableId, Option<u32>)>()
+            .into_tuple::<(TableId, Option<i32>)>()
             .all(&inner.db)
             .await?;
 
         Ok(table_options
             .into_iter()
-            .map(|(id, retention_seconds)| (id, TableOption { retention_seconds }))
+            .map(|(id, retention_seconds)| {
+                (
+                    id,
+                    TableOption {
+                        retention_seconds: retention_seconds.map(|i| i.try_into().unwrap()),
+                    },
+                )
+            })
             .collect())
     }