diff --git a/be/src/io/cache/cached_remote_file_reader.cpp b/be/src/io/cache/cached_remote_file_reader.cpp index aaa1e5f4feb920..baf5a4792ea2a6 100644 --- a/be/src/io/cache/cached_remote_file_reader.cpp +++ b/be/src/io/cache/cached_remote_file_reader.cpp @@ -151,6 +151,7 @@ Status CachedRemoteFileReader::read_at_impl(size_t offset, Slice result, size_t* ReadStatistics stats; MonotonicStopWatch read_at_sw; read_at_sw.start(); + stats.bytes_read += bytes_req; auto defer_func = [&](int*) { if (config::print_stack_when_cache_miss) { if (io_ctx->file_cache_stats == nullptr && !stats.hit_cache && !io_ctx->is_warmup) { @@ -174,7 +175,6 @@ Status CachedRemoteFileReader::read_at_impl(size_t offset, Slice result, size_t* } }; std::unique_ptr defer((int*)0x01, std::move(defer_func)); - stats.bytes_read += bytes_req; if (_is_doris_table && config::enable_read_cache_file_directly) { // read directly SCOPED_RAW_TIMER(&stats.read_cache_file_directly_timer); @@ -419,7 +419,6 @@ void CachedRemoteFileReader::_update_stats(const ReadStatistics& read_stats, statis->inverted_index_remote_io_timer += read_stats.remote_read_timer; } - g_skip_cache_num << read_stats.skip_cache; g_skip_cache_sum << read_stats.skip_cache; } diff --git a/be/src/vec/exec/scan/new_olap_scanner.cpp b/be/src/vec/exec/scan/new_olap_scanner.cpp index 7711fd5e3ede11..33a7e54f8b78ac 100644 --- a/be/src/vec/exec/scan/new_olap_scanner.cpp +++ b/be/src/vec/exec/scan/new_olap_scanner.cpp @@ -580,6 +580,9 @@ void NewOlapScanner::update_realtime_counters() { _query_statistics->add_scan_bytes_from_remote_storage( stats.file_cache_stats.bytes_read_from_remote); } + + io::FileCacheProfileReporter cache_profile(local_state->_segment_profile.get()); + cache_profile.update(&stats.file_cache_stats); DorisMetrics::instance()->query_scan_bytes_from_local->increment( stats.file_cache_stats.bytes_read_from_local); DorisMetrics::instance()->query_scan_bytes_from_remote->increment(