-
Notifications
You must be signed in to change notification settings - Fork 3.7k
[Improvement](cloud) Hold tablets in another RPC thread #52879
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
Conversation
|
run buildall |
|
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
|
run buildall |
TPC-H: Total hot run time: 33223 ms |
TPC-DS: Total hot run time: 185577 ms |
ClickBench: Total hot run time: 29.84 s |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
|
run buildall |
TPC-H: Total hot run time: 33231 ms |
TPC-DS: Total hot run time: 185766 ms |
ClickBench: Total hot run time: 29.72 s |
|
run buildall |
TPC-H: Total hot run time: 33335 ms |
TPC-DS: Total hot run time: 184087 ms |
ClickBench: Total hot run time: 29.78 s |
|
run buildall |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
|
run buildall |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
|
run buildall |
|
run buildall |
TPC-H: Total hot run time: 33354 ms |
TPC-DS: Total hot run time: 187594 ms |
ClickBench: Total hot run time: 29.88 s |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
|
|
||
| Status OlapScanLocalState::init(RuntimeState* state, LocalStateInfo& info) { | ||
| RETURN_IF_ERROR(Base::init(state, info)); | ||
| RETURN_IF_ERROR(_sync_cloud_tablets(state)); |
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.
这个_sync_cloud_tablets 实际是一个执行逻辑,但是我们把他放到了一个初始化的逻辑里,可能会有一些不可预期的问题
| _tablets.resize(_scan_ranges.size()); | ||
| _tasks.reserve(_scan_ranges.size()); | ||
| _sync_statistics.resize(_scan_ranges.size()); | ||
| SCOPED_RAW_TIMER(&_duration_ns); |
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.
这个_duration_ns 似乎没用,因为底下这个调用是异步的。
可能我们需要跟踪一下那个dependency的时间,比如他set ready的时候,记录一个时间,这样才是准确的。
|
run buildall |
|
PR approved by at least one committer and no changes requested. |
|
PR approved by anyone and no changes requested. |
TPC-H: Total hot run time: 34017 ms |
TPC-DS: Total hot run time: 186876 ms |
ClickBench: Total hot run time: 31.95 s |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
1 similar comment
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
With cloud mode on, remote tablets will be loaded into local storage before execution. This will block execution thread now. If it's too slow, pipeline execution thread may hang. This PR makes remote tablets loading asynchronously.
With cloud mode on, remote tablets will be loaded into local storage before execution. This will block execution thread now. If it's too slow, pipeline execution thread may hang. This PR makes remote tablets loading asynchronously.
What problem does this PR solve?
With cloud mode on, remote tablets will be loaded into local storage before execution. This will block execution thread now. If it's too slow, pipeline execution thread may hang.
This PR makes remote tablets loading asynchronously.
Check List (For Author)
Test
Behavior changed:
Does this need documentation?
Check List (For Reviewer who merge this PR)