Skip to content

Commit 04c6ce3

Browse files
committed
fix
1 parent 6366c16 commit 04c6ce3

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/query/storages/fuse/src/operations/read/parquet_data_source_deserializer.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,6 @@ use crate::pruning::ExprBloomFilter;
5959

6060
pub struct DeserializeDataTransform {
6161
ctx: Arc<dyn TableContext>,
62-
table_index: IndexType,
6362
scan_id: usize,
6463
scan_progress: Arc<Progress>,
6564
block_reader: Arc<BlockReader>,
@@ -122,7 +121,6 @@ impl DeserializeDataTransform {
122121
let (need_reserve_block_info, _) = need_reserve_block_info(ctx.clone(), plan.table_index);
123122
Ok(ProcessorPtr::create(Box::new(DeserializeDataTransform {
124123
ctx: ctx.clone(),
125-
table_index: plan.table_index,
126124
scan_id: plan.scan_id,
127125
scan_progress,
128126
block_reader,
@@ -148,7 +146,7 @@ impl DeserializeDataTransform {
148146
if self.cached_runtime_filter.is_none() {
149147
let bloom_filters = self
150148
.ctx
151-
.get_runtime_filters(self.table_index)
149+
.get_runtime_filters(self.scan_id)
152150
.into_iter()
153151
.filter_map(|entry| {
154152
let RuntimeFilterEntry { bloom, stats, .. } = entry;

0 commit comments

Comments
 (0)