Skip to content

Commit

Permalink
Remove +1 on lake handoff start block and use warn instead of error
Browse files Browse the repository at this point in the history
  • Loading branch information
darunrs committed Aug 6, 2024
1 parent cca0df5 commit 7981794
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions block-streamer/src/block_stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit 7981794

Please sign in to comment.