[fix](compaction) fix missing flush column during compaction (apache#…

…38356) apache#37960 introduces this problem
luwei16 · Aug 4, 2024 · a5d9332 · a5d9332
1 parent 75699c6
commit a5d9332
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
@@ -119,6 +119,7 @@ Status VerticalBetaRowsetWriter::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;
             }
         }