[doris] 20/29: [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)

[kxiao]

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 <dut.xian...@gmail.com>
AuthorDate: Fri Jun 9 08:44:41 2023 +0800

    [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)
    
    Co-authored-by: 王翔宇 <wangxian...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org