database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](dyncmic-partition) Check bucket size before find tablet. (#20488)

Browse Source 
Co-authored-by: 王翔宇 <wangxiangyu@360shuke.com>
This commit is contained in:
Xiangyu Wang
2023-06-09 08:44:41 +08:00
committed by GitHub
parent d03bd73795
commit c441cbf402
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
be/src/vec/sink/vtablet_sink.cpp
View File

@ -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()) {