From 22ac3a777c8d156893564151bc3567fbe106889c Mon Sep 17 00:00:00 2001 From: jiacai2050 Date: Thu, 27 Jul 2023 12:19:25 +0800 Subject: [PATCH] fix: disable read parquet reader --- .../src/sst/parquet/async_reader.rs | 24 ++++++++++--------- 1 file changed, 13 insertions(+), 11 deletions(-) diff --git a/analytic_engine/src/sst/parquet/async_reader.rs b/analytic_engine/src/sst/parquet/async_reader.rs index d4db2883a4..9e3d8d7264 100644 --- a/analytic_engine/src/sst/parquet/async_reader.rs +++ b/analytic_engine/src/sst/parquet/async_reader.rs @@ -363,17 +363,19 @@ impl<'a> Reader<'a> { file_path: self.path.to_string(), })?; - let object_store_reader = parquet_ext::reader::ObjectStoreReader::new( - self.store.clone(), - self.path.clone(), - Arc::new(parquet_meta_data), - ); - - let parquet_meta_data = parquet_ext::meta_data::meta_with_page_indexes(object_store_reader) - .await - .with_context(|| DecodePageIndexes { - file_path: self.path.to_string(), - })?; + // TODO: reopen following code until https://github.com/CeresDB/ceresdb/issues/1040 is fixed + // let object_store_reader = parquet_ext::reader::ObjectStoreReader::new( + // self.store.clone(), + // self.path.clone(), + // Arc::new(parquet_meta_data), + // ); + + // let parquet_meta_data = + // parquet_ext::meta_data::meta_with_page_indexes(object_store_reader) + // .await + // .with_context(|| DecodePageIndexes { + // file_path: self.path.to_string(), + // })?; MetaData::try_new(&parquet_meta_data, ignore_sst_filter) .box_err()