This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit bb6fff3455f59ba61642bbd21562f96bf2f47f55 Author: Kaijie Chen <[email protected]> AuthorDate: Mon Jan 22 20:35:18 2024 +0800 [fix](move-memtable) make sure index descriptor is set when creating delta writer (#30157) --------- Co-authored-by: Yongqiang YANG <[email protected]> Co-authored-by: Xin Liao <[email protected]> --- be/src/vec/sink/writer/vtablet_writer_v2.cpp | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp b/be/src/vec/sink/writer/vtablet_writer_v2.cpp index e23fe761ecf..cfeeb782bed 100644 --- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp +++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp @@ -431,15 +431,27 @@ Status VTabletWriterV2::_write_memtable(std::shared_ptr<vectorized::Block> block .is_high_priority = _is_high_priority, .write_file_cache = _write_file_cache, }; + bool index_not_found = true; for (const auto& index : _schema->indexes()) { if (index->index_id == rows.index_id) { req.slots = &index->slots; req.schema_hash = index->schema_hash; + index_not_found = false; break; } } + if (index_not_found) { + LOG(WARNING) << "index " << rows.index_id + << " not found in schema, load_id=" << print_id(_load_id); + return std::unique_ptr<DeltaWriterV2>(nullptr); + } return DeltaWriterV2::open(&req, streams, _state); }); + if (delta_writer == nullptr) { + LOG(WARNING) << "failed to open DeltaWriter for tablet " << tablet_id + << ", load_id=" << print_id(_load_id); + return Status::InternalError("failed to open DeltaWriter for tablet {}", tablet_id); + } { SCOPED_TIMER(_wait_mem_limit_timer); ExecEnv::GetInstance()->memtable_memory_limiter()->handle_memtable_flush(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
