Skip to content

Commit

Permalink
test: Don't hold file handle to test
Browse files Browse the repository at this point in the history
  • Loading branch information
evenyag committed Mar 27, 2023
1 parent d7d5910 commit 50a3a13
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/storage/src/sst/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ fn decode_timestamp_range_inner(

pub struct ParquetReader {
// Holds the file handle to avoid the file purge purge it.
file_handle: FileHandle,
file_path: String,
object_store: ObjectStore,
projected_schema: ProjectedSchemaRef,
predicate: Predicate,
Expand All @@ -250,7 +250,7 @@ impl ParquetReader {
time_range: TimestampRange,
) -> ParquetReader {
ParquetReader {
file_handle,
file_path: file_handle.file_path(),
object_store,
projected_schema,
predicate,
Expand All @@ -259,7 +259,7 @@ impl ParquetReader {
}

pub async fn chunk_stream(&self) -> Result<ChunkStream> {
let file_path = self.file_handle.file_path();
let file_path = self.file_path.clone();
let operator = self.object_store.clone();
let reader = operator
.object(&file_path)
Expand Down

0 comments on commit 50a3a13

Please sign in to comment.