From 3d39d0ea471cdcc46e139ff0472e8ca1d980e6e8 Mon Sep 17 00:00:00 2001 From: meiyi Date: Thu, 10 Oct 2024 11:43:51 +0800 Subject: [PATCH] fix --- be/src/olap/compaction.cpp | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/be/src/olap/compaction.cpp b/be/src/olap/compaction.cpp index d915e1f890bbfb..8b37e9ba174f2c 100644 --- a/be/src/olap/compaction.cpp +++ b/be/src/olap/compaction.cpp @@ -186,11 +186,15 @@ Status Compaction::merge_input_rowsets() { Status res; { SCOPED_TIMER(_merge_rowsets_latency_timer); - if (_is_vertical || !_tablet->tablet_schema()->cluster_key_idxes().empty()) { + if (_is_vertical) { res = Merger::vertical_merge_rowsets(_tablet, compaction_type(), *_cur_tablet_schema, input_rs_readers, _output_rs_writer.get(), get_avg_segment_rows(), way_num, &_stats); } else { + if (!_tablet->tablet_schema()->cluster_key_idxes().empty()) { + return Status::InternalError( + "mow table with cluster keys does not support non vertical compaction"); + } res = Merger::vmerge_rowsets(_tablet, compaction_type(), *_cur_tablet_schema, input_rs_readers, _output_rs_writer.get(), &_stats); }