clear cache

SkyFan2002 · SkyFan2002 · commit 9cbd40003dee · 2025-05-07T10:54:38.000+08:00
diff --git a/src/query/storages/fuse/src/operations/read/parquet_rows_fetcher.rs b/src/query/storages/fuse/src/operations/read/parquet_rows_fetcher.rs
@@ -69,6 +69,7 @@ impl<const BLOCKING_IO: bool> RowsFetcher for ParquetRowsFetcher<BLOCKING_IO> {
 
     fn clear_cache(&mut self) {
         self.part_map.clear();
+        self.segment_blocks_cache.clear();
     }
 
     #[async_backtrace::framed]

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,7 @@ impl<const BLOCKING_IO: bool> RowsFetcher for ParquetRowsFetcher<BLOCKING_IO> {`
`69`	`69`
`70`	`70`	`fn clear_cache(&mut self) {`
`71`	`71`	`self.part_map.clear();`
	`72`	`+ self.segment_blocks_cache.clear();`
`72`	`73`	`}`
`73`	`74`
`74`	`75`	`#[async_backtrace::framed]`