This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new cf5c666b949 Pick "[fix](SegComp) Don't call file writer close multi
times for segcompaction #34818" (#34820)
cf5c666b949 is described below
commit cf5c666b9496e8c66462b6268c53927880f1de40
Author: AlexYue <[email protected]>
AuthorDate: Tue May 14 14:48:51 2024 +0800
Pick "[fix](SegComp) Don't call file writer close multi times for
segcompaction #34818" (#34820)
---
be/src/olap/rowset/beta_rowset_writer.cpp | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/be/src/olap/rowset/beta_rowset_writer.cpp
b/be/src/olap/rowset/beta_rowset_writer.cpp
index b5a7167d103..40046342803 100644
--- a/be/src/olap/rowset/beta_rowset_writer.cpp
+++ b/be/src/olap/rowset/beta_rowset_writer.cpp
@@ -669,7 +669,9 @@ Status BetaRowsetWriter::_close_file_writers() {
}
RETURN_NOT_OK_STATUS_WITH_WARN(_segcompaction_rename_last_segments(),
"rename last segments failed when build
new rowset");
- if (_segcompaction_worker->get_file_writer()) {
+ if (auto& seg_comp_writer = _segcompaction_worker->get_file_writer();
+ nullptr != seg_comp_writer &&
+ seg_comp_writer->closed() != io::FileWriterState::CLOSED) {
RETURN_NOT_OK_STATUS_WITH_WARN(_segcompaction_worker->get_file_writer()->close(),
"close segment compaction worker
failed");
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
