This is an automated email from the ASF dual-hosted git repository.
caiconghui pushed a commit to branch tablet_index
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/tablet_index by this push:
new 305f448d80b format
305f448d80b is described below
commit 305f448d80b4cf7f867fd2b725165d278e56cf49
Author: caiconghui1 <[email protected]>
AuthorDate: Wed Nov 8 22:30:40 2023 +0800
format
---
be/src/exec/tablet_info.h | 2 +-
be/src/vec/sink/vtablet_finder.cpp | 6 ++++--
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/be/src/exec/tablet_info.h b/be/src/exec/tablet_info.h
index 9b735cc0117..f4daf2ca64f 100644
--- a/be/src/exec/tablet_info.h
+++ b/be/src/exec/tablet_info.h
@@ -232,7 +232,7 @@ public:
} else {
// compute and save in buffer
(*partition_tablets_buffer)[partition_id] =
tablet_indexes[index] =
- compute_function(block, index, *partitions[index]);
+ compute_function(block, index, *partitions[index]);
}
}
}
diff --git a/be/src/vec/sink/vtablet_finder.cpp
b/be/src/vec/sink/vtablet_finder.cpp
index 25109bb87f3..ea5a7f333cc 100644
--- a/be/src/vec/sink/vtablet_finder.cpp
+++ b/be/src/vec/sink/vtablet_finder.cpp
@@ -97,11 +97,13 @@ Status OlapTabletFinder::find_tablets(RuntimeState* state,
Block* block, int row
_vpartition->find_tablets(block, qualified_rows, partitions,
tablet_index);
} else {
// for random distribution
- _vpartition->find_tablets(block, qualified_rows, partitions,
tablet_index, &_partition_to_tablet_map);
+ _vpartition->find_tablets(block, qualified_rows, partitions,
tablet_index,
+ &_partition_to_tablet_map);
if (_find_tablet_mode == FindTabletMode::FIND_TABLET_EVERY_BATCH) {
for (auto row_index : qualified_rows) {
auto partition = partitions[row_index];
- if (_partition_to_tablet_map.find(partition->id) !=
_partition_to_tablet_map.end()) {
+ if (_partition_to_tablet_map.find(partition->id) !=
+ _partition_to_tablet_map.end()) {
// do round-robin for next batch
if (partition->load_tablet_idx != -1) {
partition->load_tablet_idx++;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
