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/07/11 14:56:56 UTC
[doris] 14/30: [enhancement](flush) make writer write fail status visible (#21530)
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 91351014bfc2a7ec7619b7281c5e7772bdfad0a2
Author: Siyang Tang <82...@users.noreply.github.com>
AuthorDate: Mon Jul 10 17:14:33 2023 +0800
[enhancement](flush) make writer write fail status visible (#21530)
---
be/src/olap/rowset/beta_rowset_writer.cpp | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/be/src/olap/rowset/beta_rowset_writer.cpp b/be/src/olap/rowset/beta_rowset_writer.cpp
index 1fec1c59d5..e8274b2e89 100644
--- a/be/src/olap/rowset/beta_rowset_writer.cpp
+++ b/be/src/olap/rowset/beta_rowset_writer.cpp
@@ -794,8 +794,8 @@ Status BetaRowsetWriter::_flush_segment_writer(std::unique_ptr<segment_v2::Segme
uint64_t index_size;
Status s = (*writer)->finalize(&segment_size, &index_size);
if (!s.ok()) {
- return Status::Error<WRITER_DATA_WRITE_ERROR>("failed to finalize segment: {}",
- s.to_string());
+ LOG(WARNING) << "failed to finalize segment: " << s.to_string();
+ return Status::Error(s.code());
}
VLOG_DEBUG << "tablet_id:" << _context.tablet_id
<< " flushing filename: " << (*writer)->get_data_dir()->path()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org