From 7981794c4a5db407a73767f710875e1470601c42 Mon Sep 17 00:00:00 2001 From: Darun Seethammagari Date: Tue, 6 Aug 2024 15:06:35 -0700 Subject: [PATCH] Remove +1 on lake handoff start block and use warn instead of error --- block-streamer/src/block_stream.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs index 9e536070..9489eaad 100644 --- a/block-streamer/src/block_stream.rs +++ b/block-streamer/src/block_stream.rs @@ -187,7 +187,7 @@ impl BlockStream { health_lock.processing_state = ProcessingState::Waiting; } Ordering::Equal => { - tracing::error!( + tracing::warn!( account_id = config.account_id.as_str(), function_name = config.function_name, "No block has been processed for {stalled_timeout_seconds} seconds" @@ -352,7 +352,7 @@ pub(crate) async fn start_block_stream( .context("Failed while fetching and streaming bitmap indexer blocks")?; let last_indexed_near_lake_block = process_near_lake_blocks( - last_bitmap_indexer_block + 1, + last_bitmap_indexer_block, lake_s3_client, lake_prefetch_size, redis,