From 8130f3701b27b31dd7d999e6cd5d4b71ddc7120f Mon Sep 17 00:00:00 2001 From: Vaibhav Rabber Date: Wed, 13 Nov 2024 17:16:19 +0530 Subject: [PATCH] rename var Signed-off-by: Vaibhav Rabber --- src/streams.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/streams.rs b/src/streams.rs index 54a3fd3..c1dc450 100644 --- a/src/streams.rs +++ b/src/streams.rs @@ -195,7 +195,7 @@ impl AppendRecordStream { // Next linger duration should be none. Duration::ZERO } else { - let batch_size = batch.len() as u64; + let batch_len = batch.len() as u64; yield types::AppendInput { records: batch, @@ -204,7 +204,7 @@ impl AppendRecordStream { }; if let Some(m) = next_match_seq_num.as_mut() { - *m += batch_size; + *m += batch_len; } // Next linger durationis same as the original.