Skip to content

Commit 71e8bf0

Browse files
committed
add more debug
1 parent 613567c commit 71e8bf0

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

src/query/storages/fuse/src/io/read/block_reader_parquet.rs

+10-3
Original file line numberDiff line numberDiff line change
@@ -335,9 +335,16 @@ impl BlockReader {
335335
let column_start = column_meta.offset;
336336
let column_end = column_start + column_meta.len;
337337

338-
let range_idx = range_merger.get(column_start..column_end).unwrap();
339-
let data = &merge_results[range_idx].1;
340-
let range = &ranges[range_idx];
338+
let range_idx = range_merger.get(column_start..column_end);
339+
let idx = match range_idx {
340+
None => Err(ErrorCode::Internal(format!(
341+
"it's a bug, not found range:[{},{}], in {:?}",
342+
column_start, column_end, ranges
343+
))),
344+
Some(v) => Ok(v),
345+
}?;
346+
let data = &merge_results[idx].1;
347+
let range = &ranges[idx];
341348
let column_data = data
342349
[(column_start - range.start) as usize..(column_end - column_start) as usize]
343350
.to_vec();

0 commit comments

Comments
 (0)