This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch opt_perf
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/opt_perf by this push:
new b65178b7a7 [bugfix](scanner) olap scanner compute is wrong
b65178b7a7 is described below
commit b65178b7a7df72efc7d1d275b4dc4116bb9413e2
Author: yiguolei <[email protected]>
AuthorDate: Thu Sep 22 15:06:06 2022 +0800
[bugfix](scanner) olap scanner compute is wrong
---
be/src/exec/olap_scan_node.cpp | 2 +-
be/src/vec/exec/scan/new_olap_scan_node.cpp | 2 +-
be/src/vec/exec/volap_scan_node.cpp | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/exec/olap_scan_node.cpp b/be/src/exec/olap_scan_node.cpp
index e49fdde6d1..d3b3a3aabd 100644
--- a/be/src/exec/olap_scan_node.cpp
+++ b/be/src/exec/olap_scan_node.cpp
@@ -921,7 +921,7 @@ Status OlapScanNode::start_scan_thread(RuntimeState* state)
{
int size_based_scanners_per_tablet = 1;
if (config::doris_scan_range_max_mb > 0) {
size_based_scanners_per_tablet = std::max(
- 1, (int)tablet->tablet_footprint() /
config::doris_scan_range_max_mb << 20);
+ 1, (int)(tablet->tablet_footprint() /
(config::doris_scan_range_max_mb << 20)));
}
int ranges_per_scanner =
std::max(1, (int)ranges->size() /
diff --git a/be/src/vec/exec/scan/new_olap_scan_node.cpp
b/be/src/vec/exec/scan/new_olap_scan_node.cpp
index 973e6c23ee..8242abef77 100644
--- a/be/src/vec/exec/scan/new_olap_scan_node.cpp
+++ b/be/src/vec/exec/scan/new_olap_scan_node.cpp
@@ -290,7 +290,7 @@ Status
NewOlapScanNode::_init_scanners(std::list<VScanner*>* scanners) {
if (config::doris_scan_range_max_mb > 0) {
size_based_scanners_per_tablet = std::max(
- 1, (int)tablet->tablet_footprint() /
config::doris_scan_range_max_mb << 20);
+ 1, (int)(tablet->tablet_footprint() /
(config::doris_scan_range_max_mb << 20)));
}
int ranges_per_scanner =
diff --git a/be/src/vec/exec/volap_scan_node.cpp
b/be/src/vec/exec/volap_scan_node.cpp
index 8197c88dbd..ebe6ab90cd 100644
--- a/be/src/vec/exec/volap_scan_node.cpp
+++ b/be/src/vec/exec/volap_scan_node.cpp
@@ -912,7 +912,7 @@ Status VOlapScanNode::start_scan_thread(RuntimeState*
state) {
if (config::doris_scan_range_max_mb > 0) {
size_based_scanners_per_tablet = std::max(
- 1, (int)tablet->tablet_footprint() /
config::doris_scan_range_max_mb << 20);
+ 1, (int)(tablet->tablet_footprint() /
(config::doris_scan_range_max_mb << 20)));
}
int ranges_per_scanner =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
