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
commit 8f27eacacbc9a01f65c9a8053e85c37dfe30a7bb
Author: Luwei <814383...@qq.com>
AuthorDate: Thu Jul 25 22:39:21 2024 +0800
[fix](compaction) fix missing flush column during compaction (#38356)
#37960 introduces this problem
---
be/src/olap/rowset/vertical_beta_rowset_writer.cpp | 1 +
1 file changed, 1 insertion(+)
diff --git a/be/src/olap/rowset/vertical_beta_rowset_writer.cpp
b/be/src/olap/rowset/vertical_beta_rowset_writer.cpp
index e0c1b65059f..863f0f597aa 100644
--- a/be/src/olap/rowset/vertical_beta_rowset_writer.cpp
+++ b/be/src/olap/rowset/vertical_beta_rowset_writer.cpp
@@ -106,6 +106,7 @@ Status VerticalBetaRowsetWriter<T>::add_columns(const
vectorized::Block* block,
if (num_rows_key_group == num_rows_written + to_write &&
_cur_writer_idx < _segment_writers.size() - 1) {
+
RETURN_IF_ERROR(_flush_columns(_segment_writers[_cur_writer_idx].get()));
++_cur_writer_idx;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
