Skip to content

Commit

Permalink
Change checkpoint creation logs from info to debug (#423)
Browse files Browse the repository at this point in the history
  • Loading branch information
mosyp authored Sep 3, 2021
1 parent e107122 commit 200ceee
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions rust/src/checkpoints.rs
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ async fn create_checkpoint(
let delta_log_uri = storage.join_path(table_uri, "_delta_log");
let last_checkpoint_uri = storage.join_path(&delta_log_uri, "_last_checkpoint");

info!("Writing parquet bytes to checkpoint buffer.");
debug!("Writing parquet bytes to checkpoint buffer.");
let parquet_bytes = parquet_bytes_from_state(state)?;

let size = parquet_bytes.len() as i64;
Expand All @@ -124,13 +124,13 @@ async fn create_checkpoint(
let file_name = format!("{:020}.checkpoint.parquet", version);
let checkpoint_uri = storage.join_path(&delta_log_uri, &file_name);

info!("Writing checkpoint to {:?}.", checkpoint_uri);
debug!("Writing checkpoint to {:?}.", checkpoint_uri);
storage.put_obj(&checkpoint_uri, &parquet_bytes).await?;

let last_checkpoint_content: Value = serde_json::to_value(&checkpoint)?;
let last_checkpoint_content = serde_json::to_string(&last_checkpoint_content)?;

info!("Writing _last_checkpoint to {:?}.", last_checkpoint_uri);
debug!("Writing _last_checkpoint to {:?}.", last_checkpoint_uri);
storage
.put_obj(&last_checkpoint_uri, last_checkpoint_content.as_bytes())
.await?;
Expand Down

0 comments on commit 200ceee

Please sign in to comment.