You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/06/27 16:50:37 UTC
[doris] 05/05: [improve](error) include detailed messages in rowset reader init error (#21229)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit cd908f28ea02e2b4887cd04b7e38ac3a9360af21
Author: Kaijie Chen <ck...@apache.org>
AuthorDate: Tue Jun 27 20:45:14 2023 +0800
[improve](error) include detailed messages in rowset reader init error (#21229)
---
be/src/olap/rowset/beta_rowset_reader.cpp | 4 ++--
be/src/olap/task/index_builder.cpp | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/olap/rowset/beta_rowset_reader.cpp b/be/src/olap/rowset/beta_rowset_reader.cpp
index 5564c08740..3ec62de7a8 100644
--- a/be/src/olap/rowset/beta_rowset_reader.cpp
+++ b/be/src/olap/rowset/beta_rowset_reader.cpp
@@ -224,7 +224,7 @@ Status BetaRowsetReader::get_segment_iterators(RowsetReaderContext* read_context
auto s = seg_ptr->new_iterator(_input_schema, _read_options, &iter);
if (!s.ok()) {
LOG(WARNING) << "failed to create iterator[" << seg_ptr->id() << "]: " << s.to_string();
- return Status::Error<ROWSET_READER_INIT>();
+ return Status::Error<ROWSET_READER_INIT>(s.to_string());
}
if (iter->empty()) {
continue;
@@ -268,7 +268,7 @@ Status BetaRowsetReader::init(RowsetReaderContext* read_context,
if (!s.ok()) {
LOG(WARNING) << "failed to init iterator: " << s.to_string();
_iterator.reset();
- return Status::Error<ROWSET_READER_INIT>();
+ return Status::Error<ROWSET_READER_INIT>(s.to_string());
}
return Status::OK();
}
diff --git a/be/src/olap/task/index_builder.cpp b/be/src/olap/task/index_builder.cpp
index 4a82240474..4717dff9b3 100644
--- a/be/src/olap/task/index_builder.cpp
+++ b/be/src/olap/task/index_builder.cpp
@@ -189,7 +189,7 @@ Status IndexBuilder::handle_single_rowset(RowsetMetaSharedPtr output_rowset_meta
if (!res.ok()) {
LOG(WARNING) << "failed to create iterator[" << seg_ptr->id()
<< "]: " << res.to_string();
- return Status::Error<ErrorCode::ROWSET_READER_INIT>();
+ return Status::Error<ErrorCode::ROWSET_READER_INIT>(res.to_string());
}
std::shared_ptr<vectorized::Block> block = std::make_shared<vectorized::Block>(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org