Skip to content

Commit f73d18d

Browse files
committed
fix
1 parent 631ea6a commit f73d18d

2 files changed

Lines changed: 4 additions & 6 deletions

File tree

‎src/paimon/common/utils/read_ahead_cache.cpp‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -285,10 +285,8 @@ void ReadAheadCache::Impl::CollectMetrics(const std::shared_ptr<Metrics>& metric
285285
misses_.load(std::memory_order_relaxed));
286286
metrics->SetCounter(ReadAheadCacheMetrics::READ_MISS_BYTES,
287287
miss_bytes_.load(std::memory_order_relaxed));
288-
metrics->SetCounter(ReadAheadCacheMetrics::IO_COUNT,
289-
io_count_.load(std::memory_order_relaxed));
290-
metrics->SetCounter(ReadAheadCacheMetrics::IO_BYTES,
291-
io_bytes_.load(std::memory_order_relaxed));
288+
metrics->SetCounter(ReadAheadCacheMetrics::IO_COUNT, io_count_.load(std::memory_order_relaxed));
289+
metrics->SetCounter(ReadAheadCacheMetrics::IO_BYTES, io_bytes_.load(std::memory_order_relaxed));
292290
}
293291

294292
void ReadAheadCache::Impl::Warmup() {

‎src/paimon/format/parquet/parquet_reader_builder.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,8 @@ class ParquetReaderBuilder : public ReaderBuilder {
7878
std::move(unique_input_stream));
7979
PAIMON_ASSIGN_OR_RAISE(std::shared_ptr<::parquet::FileMetaData> file_metadata,
8080
GetCachedParquetMetadata(input_stream, file_uri, arrow_pool));
81-
return ParquetFileBatchReader::Create(std::move(input_stream), options_,
82-
batch_size_, std::move(file_metadata),
81+
return ParquetFileBatchReader::Create(std::move(input_stream), options_, batch_size_,
82+
std::move(file_metadata),
8383
std::move(storage_read_bytes), arrow_pool);
8484
}
8585
PAIMON_PARQUET_CATCH_AND_RETURN_STATUS("ParquetReaderBuilder::Build")

0 commit comments

Comments
 (0)