Skip to content

Commit

Permalink
Fix the bug of SpillMemTableSink checking keys type
Browse files Browse the repository at this point in the history
Signed-off-by: trueeyu <[email protected]>
  • Loading branch information
trueeyu committed Jan 16, 2025
1 parent 5d145b0 commit 4616e64
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion be/src/storage/lake/spill_mem_table_sink.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -218,7 +218,7 @@ Status SpillMemTableSink::merge_blocks_to_segments() {
total_merges++;
// PK shouldn't do agg because pk support order key different from primary key,
// in that case, data is sorted by order key and cannot be aggregated by primary key
bool do_agg = _schema->keys_type() == TKeysType::AGG_KEYS || _schema->keys_type() == TKeysType::UNIQUE_KEYS;
bool do_agg = _schema->keys_type() == KeysType::AGG_KEYS || _schema->keys_type() == KeysType::UNIQUE_KEYS;
auto tmp_itr = new_heap_merge_iterator(merge_inputs);
auto merge_itr = do_agg ? new_aggregate_iterator(tmp_itr) : tmp_itr;
RETURN_IF_ERROR(merge_itr->init_encoded_schema(EMPTY_GLOBAL_DICTMAPS));
Expand Down

0 comments on commit 4616e64

Please sign in to comment.