database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[add_log](checksum) add cost and size log for checksum (#15599)

Browse Source
This commit is contained in:
yixiutt
2023-01-04 19:10:40 +08:00
committed by GitHub
parent 4075e3aec6
commit 804ea08825
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/olap/task/engine_checksum_task.cpp
View File

@ -39,6 +39,7 @@ Status EngineChecksumTask::_compute_checksum() {
LOG(INFO) << "begin to process compute checksum."
<< "tablet_id=" << _tablet_id << ", schema_hash=" << _schema_hash
<< ", version=" << _version;
OlapStopWatch watch;
if (_checksum == nullptr) {
return Status::InvalidArgument("invalid checksum which is nullptr");
@ -57,6 +58,10 @@ Status EngineChecksumTask::_compute_checksum() {
<< "res=" << acquire_reader_st;
return acquire_reader_st;
}
size_t input_size = 0;
for (const auto& rowset : input_rowsets) {
input_size += rowset->data_disk_size();
}
vectorized::BlockReader reader;
TabletReader::ReaderParams reader_params;
vectorized::Block block;
@ -83,7 +88,8 @@ Status EngineChecksumTask::_compute_checksum() {
*_checksum = (checksum64 >> 32) ^ (checksum64 & 0xffffffff);
LOG(INFO) << "success to finish compute checksum. tablet_id = " << _tablet_id
<< ", rows = " << rows << ", checksum=" << *_checksum;
<< ", rows = " << rows << ", checksum=" << *_checksum
<< ", total_size = " << input_size << ", cost(us): " << watch.get_elapse_time_us();
return Status::OK();
}