diff --git a/crates/control_plane/src/models/mod.rs b/crates/control_plane/src/models/mod.rs index 403ed99f7..b44d00837 100644 --- a/crates/control_plane/src/models/mod.rs +++ b/crates/control_plane/src/models/mod.rs @@ -454,7 +454,8 @@ impl ColumnInfo { | DataType::UInt8 | DataType::UInt16 | DataType::UInt32 - | DataType::UInt64 => { + | DataType::UInt64 + | DataType::Float32 => { column_info.r#type = "fixed".to_string(); column_info.precision = Some(38); column_info.scale = Some(0); diff --git a/crates/control_plane/src/utils.rs b/crates/control_plane/src/utils.rs index 5b553f53a..5529b5bda 100644 --- a/crates/control_plane/src/utils.rs +++ b/crates/control_plane/src/utils.rs @@ -73,8 +73,6 @@ pub fn convert_record_batches( columns.push(converted_column); } let new_schema = Arc::new(Schema::new(fields)); - //println!("new schema: {:?}", new_schema); - //println!("columns: {:?}", columns); let converted_batch = RecordBatch::try_new(new_schema, columns)?; converted_batches.push(converted_batch); }