From c441cbf40240a8d0b7189f8a86536ddbc8de54da Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Fri, 9 Jun 2023 08:44:41 +0800 Subject: [PATCH] [Fix](dyncmic-partition) Check bucket size before find tablet. (#20488) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 王翔宇 --- 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()) {