[doris] branch master updated: [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)

[yi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new c441cbf402 [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)
c441cbf402 is described below

commit c441cbf40240a8d0b7189f8a86536ddbc8de54da
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 813d972b63..ba8cf21fc7 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