This commit is contained in:
Peter Zhang 2025-11-20 22:07:27 +08:00
parent c2f2fbb934
commit 1bbe6127db

View File

@ -278,6 +278,11 @@ impl FlowWrite for FlowStore {
batch_list.push((chunk_index, batch)); batch_list.push((chunk_index, batch));
} }
// print which indexes are being pushed to batch_list
for (chunk_index, _) in &batch_list {
debug!("Preparing to insert chunk at index: {}", chunk_index);
}
metrics::APPEND_ENTRIES.update_since(start_time); metrics::APPEND_ENTRIES.update_since(start_time);
let res = self.data_db.put_entry_batch_list(batch_list); let res = self.data_db.put_entry_batch_list(batch_list);