diff --git a/src/parseable/staging/writer.rs b/src/parseable/staging/writer.rs
index b4def9145..bd5a1ca60 100644
--- a/src/parseable/staging/writer.rs
+++ b/src/parseable/staging/writer.rs
@@ -83,6 +83,7 @@ impl<const N: usize> DiskWriter<N> {
             }
         } else {
             self.inner.write(rb)?;
+            self.count += rb.num_rows();
         }
 
         Ok(())