Update crates/fluss/src/metadata/json_serde.rs

Co-authored-by: Copilot <[email protected]>

Author: pavlospt

crates/fluss/src/metadata/json_serde.rs

@@ -173,21 +173,21 @@ impl JsonSerde for DataType {
                 let length = node
                     .get(Self::FIELD_NAME_LENGTH)
                     .and_then(|v| v.as_u64())
-                    .unwrap_or(1) as u32;
+                    .ok_or_else(|| JsonSerdeError(format!("Missing required field: {}", Self::FIELD_NAME_LENGTH)))? as u32;
                 DataTypes::char(length)
-            },
+            }
             "STRING" => DataTypes::string(),
             "DECIMAL" => {
                 let precision = node
                     .get(Self::FIELD_NAME_PRECISION)
                     .and_then(|v| v.as_u64())
-                    .unwrap_or(10) as u32;
+                    .ok_or_else(|| JsonSerdeError(format!("Missing required field: {}", Self::FIELD_NAME_PRECISION)))? as u32;
                 let scale = node
                     .get(Self::FIELD_NAME_SCALE)
                     .and_then(|v| v.as_u64())
                     .unwrap_or(0) as u32;
                 DataTypes::decimal(precision, scale)
-            },
+            }
             "DATE" => DataTypes::date(),
             "TIME_WITHOUT_TIME_ZONE" => {
                 let precision = node
@@ -334,7 +334,7 @@ impl JsonSerde for Column {
         let name = node
             .get(Self::NAME)
             .and_then(|v| v.as_str())
-            .unwrap_or_else(|| panic!("{}", format!("Missing required field: {}", Self::NAME)))
+            .ok_or_else(|| JsonSerdeError(format!("Missing required field: {}", Self::NAME)))?
             .to_string();
 
         let data_type_node = node.get(Self::DATA_TYPE).ok_or_else(|| {
@@ -438,7 +438,7 @@ impl TableDescriptor {
 
     fn deserialize_properties(node: &Value) -> Result<HashMap<String, String>> {
         let obj = node
-        .as_object()
+            .as_object()
         .ok_or_else(|| JsonSerdeError("Properties must be an object".to_string()))?;
 
         let mut properties = HashMap::with_capacity(obj.len());
@@ -605,7 +605,7 @@ mod tests {
             DataTypes::boolean(),
             DataTypes::tinyint(),
             DataTypes::smallint(),
-            DataTypes::int(),
+            DataTypes::int().as_non_nullable(),
             DataTypes::bigint(),
             DataTypes::float(),
             DataTypes::double(),
@@ -621,8 +621,8 @@ mod tests {
             DataTypes::array(DataTypes::int()),
             DataTypes::map(DataTypes::string(), DataTypes::int()),
             DataTypes::row(vec![
-            crate::metadata::DataField::new("f1".to_string(), DataTypes::int(), None),
-            crate::metadata::DataField::new("f2".to_string(), DataTypes::string(), Some("desc".to_string())),
+            DataField::new("f1".to_string(), DataTypes::int(), None),
+            DataField::new("f2".to_string(), DataTypes::string(), Some("desc".to_string())),
             ]),
         ];