fix ci

risingwavelabs · Dec 5, 2024 · dfb0611 · dfb0611
1 parent 8ae90aa
commit dfb0611
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/batch/src/executor/row_seq_scan.rs b/src/batch/src/executor/row_seq_scan.rs
@@ -101,7 +101,7 @@ impl From<&AsOf> for PbAsOf {
 
 impl ScanRange {
     /// Create a scan range from the prost representation.
-    pub fn new(scan_range: PbScanRange, mut pk_types: Vec<DataType>) -> Result<Self> {
+    pub fn new(scan_range: PbScanRange, pk_types: Vec<DataType>) -> Result<Self> {
         let mut index = 0;
         let pk_prefix = OwnedRow::new(
             scan_range
@@ -110,7 +110,7 @@ impl ScanRange {
                 .map(|v| {
                     let ty = pk_types.get(index).unwrap();
                     index += 1;
-                    deserialize_datum(v.as_slice(), &ty)
+                    deserialize_datum(v.as_slice(), ty)
                 })
                 .try_collect()?,
         );
@@ -129,7 +129,7 @@ impl ScanRange {
                     .map(|v| {
                         let ty = pk_types.get(index).unwrap();
                         index += 1;
-                        deserialize_datum(v.as_slice(), &ty)
+                        deserialize_datum(v.as_slice(), ty)
                     })
                     .try_collect()?,
             );