From b3c1f8a1bbde01e0daa2ed0023cbc5550480df96 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Thu, 18 Jan 2024 13:44:07 +0800 Subject: [PATCH] add prefetch options --- src/stream/src/executor/backfill/arrangement_backfill.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/stream/src/executor/backfill/arrangement_backfill.rs b/src/stream/src/executor/backfill/arrangement_backfill.rs index 4f72d62e74dfc..8cb5cd690dfc1 100644 --- a/src/stream/src/executor/backfill/arrangement_backfill.rs +++ b/src/stream/src/executor/backfill/arrangement_backfill.rs @@ -43,6 +43,7 @@ use crate::executor::{ Message, PkIndicesRef, StreamExecutorError, }; use crate::task::{ActorId, CreateMviewProgress}; +use risingwave_storage::store::PrefetchOptions; /// Similar to [`super::no_shuffle_backfill::BackfillExecutor`]. /// Main differences: @@ -559,7 +560,7 @@ where "iter_with_vnode_and_output_indices" ); let vnode_row_iter = upstream_table - .iter_with_vnode_and_output_indices(vnode, &range_bounds, Default::default()) + .iter_with_vnode_and_output_indices(vnode, &range_bounds, PrefetchOptions::prefetch_for_small_range_scan()) .await?; let vnode_row_iter = Box::pin(owned_row_iter(vnode_row_iter));