You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/06/09 04:10:56 UTC
[doris] 20/29: [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0-beta
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9a89ab0228a3f8aa3568c8445fd5cee7446d6c04
Author: Xiangyu Wang <du...@gmail.com>
AuthorDate: Fri Jun 9 08:44:41 2023 +0800
[Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)
Co-authored-by: 王翔宇 <wa...@360shuke.com>
---
be/src/vec/sink/vtablet_sink.cpp | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp
index a5711f4c12..7482cb18a2 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -1237,6 +1237,11 @@ Status VOlapTableSink::find_tablet(RuntimeState* state, vectorized::Block* block
is_continue = true;
return status;
}
+ if ((*partition)->num_buckets <= 0) {
+ std::stringstream ss;
+ ss << "num_buckets must be greater than 0, num_buckets=" << (*partition)->num_buckets;
+ return Status::InternalError(ss.str());
+ }
_partition_ids.emplace((*partition)->id);
if (findTabletMode != FindTabletMode::FIND_TABLET_EVERY_ROW) {
if (_partition_to_tablet_map.find((*partition)->id) == _partition_to_tablet_map.end()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org