-
Notifications
You must be signed in to change notification settings - Fork 3.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add spill metrics and improve spill log printing #46029
Add spill metrics and improve spill log printing #46029
Conversation
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
be/src/vec/spill/spill_writer.cpp
Outdated
@@ -59,6 +59,7 @@ Status SpillWriter::close() { | |||
COUNTER_UPDATE(_write_file_current_size, meta_.size()); | |||
} | |||
data_dir_->update_spill_data_usage(meta_.size()); | |||
ExecEnv::GetInstance()->spill_stream_mgr()->updat_spill_write_bytes(meta_.size()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo error
INT_UGAUGE_METRIC_REGISTER(_entity, spill_io_thread_pool_pool_max_queue_size); | ||
INT_UGAUGE_METRIC_REGISTER(_entity, spill_io_thread_pool_queue_size); | ||
|
||
_entity->register_hook("spill_io_thread_pool_max_threads", [&]() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thread pool的别加了,zhiqiang 那里给所有的thread pool 统一加
be/src/vec/spill/spill_reader.cpp
Outdated
COUNTER_UPDATE(_read_file_size, bytes_read); | ||
total_read_bytes += bytes_read; | ||
COUNTER_UPDATE(_read_file_size, total_read_bytes); | ||
ExecEnv::GetInstance()->spill_stream_mgr()->updat_spill_read_bytes(total_read_bytes); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo error
What problem does this PR solve?
Issue Number: close #xxx
Related PR: #xxx
Problem Summary:
Release note
None
Check List (For Author)
Test
Behavior changed:
Does this need documentation?
Check List (For Reviewer who merge this PR)