Skip to content

Commit

Permalink
Update rust/src/checkpoints.rs
Browse files Browse the repository at this point in the history
Co-authored-by: Christian Williams <christianwilliams79@gmail.com>
  • Loading branch information
timvw and xianwill authored Jun 19, 2022
1 parent 129eedf commit 9a649b8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion rust/src/checkpoints.rs
Original file line number Diff line number Diff line change
Expand Up @@ -400,7 +400,7 @@ fn parquet_bytes_from_state(state: &DeltaTableState) -> Result<Vec<u8>, 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);
Expand Down

0 comments on commit 9a649b8

Please sign in to comment.