diff --git a/rust/src/checkpoints.rs b/rust/src/checkpoints.rs index 42039c5b8c..3491c15664 100644 --- a/rust/src/checkpoints.rs +++ b/rust/src/checkpoints.rs @@ -400,7 +400,7 @@ fn parquet_bytes_from_state(state: &DeltaTableState) -> Result, Checkpoi debug!("Writing to checkpoint parquet buffer..."); // Write the Checkpoint parquet file. - let writeable_cursor = Cursor::new(vec![]); + let mut writeable_cursor = Cursor::new(vec![]); let mut writer = ArrowWriter::try_new(&mut writeable_cursor, arrow_schema.clone(), None)?; let options = DecoderOptions::new().with_batch_size(CHECKPOINT_RECORD_BATCH_SIZE); let decoder = Decoder::new(arrow_schema, options);