Skip to content

Commit

Permalink
add some debug logs to check my hypothesis: when the buffer reader is…
Browse files Browse the repository at this point in the history
… initialized and then catches up to the writer, it waits for the writer to notify it (but the writer will never write more data in the vector buffer recovery topology/pipeline)
  • Loading branch information
alexander-jiang committed Jan 11, 2025
1 parent 67fb2dc commit 290f56e
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions lib/vector-buffers/src/variants/disk_v2/reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -977,6 +977,7 @@ where
if self.ledger.is_writer_done() {
let total_buffer_size = self.ledger.get_total_buffer_size();
if total_buffer_size == 0 {
debug!("writer is done and total buffer size is 0");
return Ok(None);
}
}
Expand Down Expand Up @@ -1074,6 +1075,7 @@ where
continue;
}

debug!("reader is on writer's current data file: waiting for writer to wake the reader");
self.ledger.wait_for_writer().await;
} else {
debug!(
Expand Down

0 comments on commit 290f56e

Please sign in to comment.