diff --git a/lib/vector-buffers/src/variants/disk_v2/reader.rs b/lib/vector-buffers/src/variants/disk_v2/reader.rs index 8aea89645ca64..de1dbdbd19038 100644 --- a/lib/vector-buffers/src/variants/disk_v2/reader.rs +++ b/lib/vector-buffers/src/variants/disk_v2/reader.rs @@ -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); } } @@ -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!(