[fix](compaction) fix missing flush column during compaction (#38356)

#37960 introduces this problem
apache · Jul 25, 2024 · c9da17b · c9da17b
1 parent 11ecadc
commit c9da17b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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;
             }
         }